code: func (em *Emitter) Unsubscribe(ctx context.Context, subscriber string, queryable query.Queryable) error {
  	pubsubQuery, err := queryable.Query()
  	if err != nil {
  		return nil
  	}
  	return em.pubsubServer.Unsubscribe(ctx, subscriber, pubsubQuery)
  }
docs: // Unsubscribe tells the emitter to stop listening for said messages