Class ZOBinaryMessageSubscriber
Subscribes to arbitrary binary messages. Stream format: string: Topic + "\n" int32: size of data byte: data
Inheritance
System.Object
ZOBinaryMessageSubscriber
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: ZO.Networking
Assembly: Unity.ZeroSim.dll
Syntax
public class ZOBinaryMessageSubscriber
Properties
| Improve this Doc View SourceHostname
Declaration
public string Hostname { get; set; }
Property Value
Type | Description |
---|---|
System.String |
OnConnectedToPublisherDelegate
Delegate for when we are connected to a publisher. Parameters: this Returns: Async Task
Declaration
public Func<ZOBinaryMessageSubscriber, Task> OnConnectedToPublisherDelegate { get; set; }
Property Value
Type | Description |
---|---|
System.Func<ZOBinaryMessageSubscriber, System.Threading.Tasks.Task> |
OnDisconnectedFromPublisherDelegate
Delegate for when we are disconnected from a publisher. Parameters: this Returns: Async Task
Declaration
public Func<ZOBinaryMessageSubscriber, Task> OnDisconnectedFromPublisherDelegate { get; set; }
Property Value
Type | Description |
---|---|
System.Func<ZOBinaryMessageSubscriber, System.Threading.Tasks.Task> |
OnMessageReceivedDelegate
Delegate for when message is received.
Parameters: this, byte array of binary message
Returns: Async task
Declaration
public Func<ZOBinaryMessageSubscriber, byte[], Task> OnMessageReceivedDelegate { get; set; }
Property Value
Type | Description |
---|---|
System.Func<ZOBinaryMessageSubscriber, System.Byte[], System.Threading.Tasks.Task> |
Port
Declaration
public int Port { get; set; }
Property Value
Type | Description |
---|---|
System.Int32 |
Topic
Declaration
public string Topic { get; set; }
Property Value
Type | Description |
---|---|
System.String |
Methods
| Improve this Doc View SourceRunAsync()
Run asynchronously
Declaration
public Task RunAsync()
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task |
Stop()
Stops subscription
Declaration
public void Stop()