外观
bus_sources API
模块说明
text
Worker-owned online sources and callbacks, sealed and actually joined on exit.BusSubscriptionError
python
class BusSubscriptionError(BusError)BusSubscriptionError.__init__
python
def __init__(self, reason, *, gap=False)BusSubscriptionError.reason
python
self.reason公开实例属性，在 __init__ 中设置。
BusSubscriptionError.gap
python
self.gap公开实例属性，在 __init__ 中设置。
BusSubscription
python
class BusSubscriptionSDK 说明：
text
One bounded short-poll subscription; caller owns serial consumption.BusSubscription.__init__
python
def __init__(self, bus, registration)BusSubscription.open
python
async def open(self)BusSubscription.__aiter__
python
def __aiter__(self)BusSubscription.__anext__
python
async def __anext__(self)BusSubscription.close
python
async def close(self)BusSubscription.bus
python
self.bus公开实例属性，在 __init__ 中设置。
BusSubscription.registration
python
self.registration公开实例属性，在 __init__ 中设置。
BusSubscription.handle
python
self.handle公开实例属性，在 __init__、close 中设置。
BusSubscription.buffer
python
self.buffer公开实例属性，在 __init__ 中设置。
BusSubscription.terminal
python
self.terminal公开实例属性，在 __init__、_batch 中设置。
BusSubscription.gap
python
self.gap公开实例属性，在 __init__、_batch 中设置。
BusSubscription.closed
python
self.closed公开实例属性，在 __init__、close 中设置。
SourceOwner
python
class SourceOwnerSDK 说明：
text
Separate bounded owner for all stream drivers; TaskOwner.open cannot start it.SourceOwner.__init__
python
def __init__(self, bus, context=None, on_failure=None, *, max_callbacks=4)SourceOwner.states
python
@property
def states(self)SourceOwner.statuses
python
@property
def statuses(self)SourceOwner.enabled
python
@property
def enabled(self)SourceOwner.check
python
def check(self)SourceOwner.start
python
def start(self, *, run_token, resume=False)SourceOwner.seal
python
def seal(self)SourceOwner.begin_join
python
def begin_join(self)SourceOwner.join
python
async def join(self)SourceOwner.complete_drain
python
def complete_drain(self)SourceOwner.bus
python
self.bus公开实例属性，在 __init__ 中设置。
SourceOwner.context
python
self.context公开实例属性，在 __init__ 中设置。
SourceOwner.state
python
self.state公开实例属性，在 __init__、start、seal、_failed、complete_drain 中设置。