koapy.backend.kiwoom_open_api_plus.utils.queue.QueueBasedIterableObserver

Module Contents

Classes

QueueBasedIterableObserverIterator
QueueBasedIterableObserver	Observer abstract base class

class koapy.backend.kiwoom_open_api_plus.utils.queue.QueueBasedIterableObserver.QueueBasedIterableObserverIterator(queue, sentinel)

Bases: koapy.backend.kiwoom_open_api_plus.utils.queue.QueueIterator.BufferedQueueIterator

next(block=True, timeout=None)

head()

class koapy.backend.kiwoom_open_api_plus.utils.queue.QueueBasedIterableObserver.QueueBasedIterableObserver(queue=None, maxsize=None)

Bases: rx.core.typing.Observer

Observer abstract base class

An Observer is the entity that receives all emissions of a subscribed Observable.

property queue

on_next(value)

Notifies the observer of a new element in the sequence.

Parameters:

value – The received element.

on_error(error)

Notifies the observer that an exception has occurred.

Parameters:

error – The error that has occurred.

on_completed()

Notifies the observer of the end of the sequence.

stop()