Skip to content

Commit

Permalink
bugfix: include all subpackges into rxbp distribution
Browse files Browse the repository at this point in the history
  • Loading branch information
MichaelSchneeberger committed Apr 15, 2020
1 parent ae62df4 commit 2284701
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 18 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ Differences from RxPY

Similar to an RxPY Observable, a *Flowable* implements a `subscribe` method,
which is a mechanism that allows to describe a data flow from its source to
some sink. The description is done with *rxbp* operators exposed by `rxbp.op`.
a sink. The description is done with *rxbp* operators exposed by `rxbp.op`.

Like in functional programming, usings *rxbp* operators
does not create any mutable states, but rather concatenates functions
Expand Down
18 changes: 3 additions & 15 deletions rxbp/flowable.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,21 +42,9 @@


class Flowable(FlowableOpMixin, FlowableBase, Generic[ValueType]):
""" A `Flowable` implements a `subscribe` method allowing to describe a
data flow from source to sink. The "description" is
done with *rxbp* operators exposed by `rxbp.op`.
Like in functional programming, usings *rxbackpressure* operators does not create
any mutable states but rather concatenates functions without calling them
yet. Or in other words, we first describe what we want to do, and then
we execute the plan. A `Flowable` is executed by calling its `subscribe`
method. This will start a chain reaction, where downsream `Flowables`
call the `subscribe` method of their linked upstream `Flowable` until
the sources start emitting data. Once a `Flowable` is subscribed, we
allow it to have mutable states where it make sense.
Compared to RxPY Observables, a `Flowable` uses `Observers` that are
able to back-pressure an `on_next` method call.
"""
A `Flowable` implements a `subscribe` method, which is a mechanism that
allows to describe a data flow from source to a sink.
"""

def __init__(self, underlying: FlowableBase):
Expand Down
4 changes: 2 additions & 2 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@

setup(
name='rxbp',
version='3.0.0a8',
version='3.0.0a9',
install_requires=['rx'],
description='An RxPY extension with back-pressure',
long_description=long_description,
Expand All @@ -24,6 +24,6 @@
'Programming Language :: Python :: 3.8',
],
keywords=['rx reactive extension back-pressure backpressure flowable multicast'],
packages=['rxbp'],
packages=find_packages(include=['rxbp', 'rxbp.*']),
python_requires='>=3.7',
)

0 comments on commit 2284701

Please sign in to comment.