Method AddSubscriber

bolt.go:147–168

AddSubscriber adds a new subscriber to the transport.

(ctx context.Context, s *LocalSubscriber)

// AddSubscriber adds a new subscriber to the transport.
func (t *BoltTransport) AddSubscriber(ctx context.Context, s *LocalSubscriber) error {
	select {
	case <-t.closed:
		return ErrClosedTransport
	default:
	}

	t.Lock()
	t.subscribers.Add(s)
	toSeq := t.lastSeq
	t.Unlock()

	if s.RequestLastEventID != "" {
		if err := t.dispatchHistory(ctx, s, toSeq); err != nil {
			return err
		}
	}

	s.Ready(ctx)

	return nil
}

// RemoveSubscriber removes a new subscriber from the transport.
func (t *BoltTransport) RemoveSubscriber(_ context.Context, s *LocalSubscriber) error {