koapy.backtrader.KiwoomOpenApiPlusEventStreamer

Module Contents

Classes

KiwoomOpenApiPlusPriceEventChannel

KiwoomOpenApiPlusOrderEventChannel

MetaKiwoomOpenApiPlusEventStreamer

Metaclass for defining Abstract Base Classes (ABCs).

KiwoomOpenApiPlusEventStreamer

Observer abstract base class

class koapy.backtrader.KiwoomOpenApiPlusEventStreamer.KiwoomOpenApiPlusPriceEventChannel(stub)[source]

Bases: koapy.utils.logging.Logging.Logging

close()[source]
initialize()[source]
register_code(code)[source]
is_for_code(response, code)[source]
filter_for_code(code)[source]
is_valid_price_event(response)[source]
filter_price_event()[source]
time_to_timestamp(fid20)[source]
event_to_dict(response)[source]
convert_to_dict()[source]
get_observable_for_code(code)[source]
class koapy.backtrader.KiwoomOpenApiPlusEventStreamer.KiwoomOpenApiPlusOrderEventChannel(stub)[source]
close()[source]
is_chejan_response(response)[source]
filter_chejan_response()[source]
event_to_dict(response)[source]
convert_to_dict()[source]
get_observable()[source]
class koapy.backtrader.KiwoomOpenApiPlusEventStreamer.MetaKiwoomOpenApiPlusEventStreamer(clsname, bases, dct)[source]

Bases: type(Logging), type(Observer)

Metaclass for defining Abstract Base Classes (ABCs).

Use this metaclass to create an ABC. An ABC can be subclassed directly, and then acts as a mix-in class. You can also register unrelated concrete classes (even built-in classes) and unrelated ABCs as ‘virtual subclasses’ – these and their descendants will be considered subclasses of the registering ABC by the built-in issubclass() function, but the registering ABC won’t show up in their MRO (Method Resolution Order) nor will method implementations defined by the registering ABC be callable (not even via super()).

class koapy.backtrader.KiwoomOpenApiPlusEventStreamer.KiwoomOpenApiPlusEventStreamer(stub, queue)[source]

Bases: rx.core.typing.Observer, koapy.utils.logging.Logging.Logging

Observer abstract base class

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

on_next(value)[source]

Notifies the observer of a new element in the sequence.

Parameters:

value – The received element.

on_error(error)[source]

Notifies the observer that an exception has occurred.

Parameters:

error – The error that has occurred.

on_completed()[source]

Notifies the observer of the end of the sequence.

rates(code)[source]
events()[source]