Skip to content

Commit

Permalink
Remove empty lines
Browse files Browse the repository at this point in the history
  • Loading branch information
dbrattli committed May 11, 2019
1 parent b26f6fd commit a689033
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions rx/core/observable/observable.py
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,6 @@ def subscribe(self, # pylint: disable=too-many-arguments,arguments-differ

return self.subscribe_(on_next, on_error, on_completed, scheduler)


def subscribe_(self,
on_next: Optional[typing.OnNext] = None,
on_error: Optional[typing.OnError] = None,
Expand Down Expand Up @@ -208,7 +207,6 @@ def set_disposable(_: abc.Scheduler = None, __: Any = None):
# Hide the identity of the auto detach observer
return Disposable(auto_detach_observer.dispose)


def pipe(self, *operators: Callable[['Observable'], 'Observable']) -> 'Observable':
"""Compose multiple operators left to right.
Expand All @@ -227,7 +225,6 @@ def pipe(self, *operators: Callable[['Observable'], 'Observable']) -> 'Observabl
from ..pipe import pipe
return pipe(*operators)(self)


def run(self) -> Any:
"""Run source synchronously.
Expand Down

0 comments on commit a689033

Please sign in to comment.