Package com.viam.sdk.core.webrtc

Class BaseChannel

java.lang.Object

com.viam.sdk.core.webrtc.BaseChannel

All Implemented Interfaces:

DataChannel.Observer

public class BaseChannel
extends Object
implements DataChannel.Observer

Constructor Summary

Constructors

Constructor	Description
BaseChannel(RPCPeerConnection rpcConn, Consumer<DataChannel.Buffer> onMessage)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isClosed()
Optional<Exception>	isClosedReason()
void	onMessage(DataChannel.Buffer buffer)
void	onStateChange()
CompletableFuture<Void>	ready()
protected void	write(com.google.protobuf.MessageLite msg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.viam.sdk.core.webrtc.DataChannel.Observer

onBufferedAmountChange

Constructor Details

BaseChannel

public BaseChannel(RPCPeerConnection rpcConn,
 Consumer<DataChannel.Buffer> onMessage)

Method Details

ready

public CompletableFuture<Void> ready()

close

public void close()

isClosed

public boolean isClosed()

isClosedReason

public Optional<Exception> isClosedReason()

write

protected void write(com.google.protobuf.MessageLite msg)

onStateChange

public void onStateChange()

Specified by:

onStateChange in interface DataChannel.Observer

onMessage

public void onMessage(DataChannel.Buffer buffer)

Specified by:

onMessage in interface DataChannel.Observer