TcpAmiDataSource class

TCP socket implementation of AmiDataSource.

Wraps a raw TCP socket connection with buffering and message parsing.

Implemented types

• AmiDataSource

Constructors

TcpAmiDataSource({AmiProtocolParser? parser})

Properties

connectionStateStream → Stream<ConnectionState>

Stream of connection state changes.

no setter, override

currentConnection → ConnectionInfo?

Current connection info (null if not connected).

no setter, override

hashCode → int

The hash code for this object.

no setter, inherited

messageStream → Stream<AmiMessage>

Stream of all incoming messages.

no setter, override

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

connect(String host, int port) → Future<ConnectionInfo>

Connects to the AMI server.

override

disconnect() → Future<void>

Disconnects from the server.

override

dispose() → void

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

sendAction(AmiAction action) → Future<void>

Sends an action to the server.

override

toString() → String

A string representation of this object.

inherited

waitForGreeting() → Future<String>

Waits for the greeting message.

override

waitForResponse(String actionId, {Duration? timeout}) → Future<AmiResponse>

Waits for a response matching the given action ID.

override

Operators

operator ==(Object other) → bool

The equality operator.

inherited