EventBusSubscribeStream class

Receiving stream for EventBus/Subscribe responses.

Constructors

EventBusSubscribeStream(ClientStream _stream)

Properties

hashCode → int
The hash code for this object.
no setterinherited
headers → Map<String, String>?
Initial metadata (response headers); null until they arrive.
no setter
responses → Stream<Event>
Responses as a Dart Stream (native async surface). Cancelling the subscription abandons the call: RST CANCELLED is sent so the server stops.
no setter
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
trailers → Map<String, String>?
Trailing metadata of the terminal status; null until it arrives.
no setter

Methods

cancel() → void
Abort this stream (sends RST, wakes a pending recv).
close() → void
Abandon the call if still live (RST); no-op once terminated.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
recv() → Future<Event>
toString() → String
A string representation of this object.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited