Versions in this module Expand all Collapse all v1 v1.0.3 Aug 21, 2023 v1.0.1 Aug 21, 2023 Changes in this version + type IncrementingNonceGenerator struct + func (m *IncrementingNonceGenerator) GetNonce() string + type TestAsync struct + Sent []interface{} + func (t *TestAsync) Close() + func (t *TestAsync) Connect() error + func (t *TestAsync) Done() <-chan error + func (t *TestAsync) DumpSentMessages() + func (t *TestAsync) Listen() <-chan []byte + func (t *TestAsync) Publish(raw string) + func (t *TestAsync) Send(ctx context.Context, msg interface{}) error + func (t *TestAsync) SentCount() int + type TestAsyncFactory struct + Async websocket.Asynchronous + Count int + func (t *TestAsyncFactory) Create() websocket.Asynchronous + type TestWsService struct + func NewTestWsService(port int) *TestWsService + func (s *TestWsService) Broadcast(msg string) + func (s *TestWsService) PublishOnConnect(msg string) + func (s *TestWsService) Received(clientNum int, msgNum int) (string, error) + func (s *TestWsService) ReceivedCount(clientNum int) int + func (s *TestWsService) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (s *TestWsService) Start() error + func (s *TestWsService) Stop() + func (s *TestWsService) TotalClientCount() int + func (s *TestWsService) WaitForClientCount(count int) error + func (s *TestWsService) WaitForMessage(clientNum int, msgNum int) (string, error)
Go to main page