Versions in this module Expand all Collapse all v0 v0.5.0 Jun 18, 2022 Changes in this version + type DummyOutSample struct + func (DummyOutSample) DecodeAbstract(*[]byte) (encoder.UserFacingHermodUnit, error) + func (DummyOutSample) GetDefinition() *encoder.Unit + type ServiceReadWriter struct + Context context.Context + Endpoint uint16 + HasIn bool + OutSample Out + Router *WebSocketRouter + func (rw *ServiceReadWriter[In, Out]) Call(data In) (*Out, error) + func (rw *ServiceReadWriter[In, Out]) Close() error + func (rw *ServiceReadWriter[In, Out]) Init(token ...string) error + func (rw *ServiceReadWriter[In, Out]) Messages() (<-chan Out, <-chan error, error) + func (rw *ServiceReadWriter[In, Out]) NextMessage(readyChan chan<- interface{}) (*Out, error) + func (rw *ServiceReadWriter[In, Out]) Send(data In) error + type WebSocketRouter struct + Timeout time.Duration + URL url.URL + func (router *WebSocketRouter) Close() error + func (router *WebSocketRouter) Connect(token ...string) error
Go to main page