osstreamwatcher

Nov 10, 2022

Changes in this version

+ const StreamAPIEndpoint

+ type OSStreamWatcher struct

+ QueueListings chan *models.ItemListedEvent

+ func NewStreamWatcher(token string, onError func(error)) *OSStreamWatcher

+ func (s *OSStreamWatcher) Connect() error

+ func (s *OSStreamWatcher) Disconnect() error

+ func (s *OSStreamWatcher) OnItemListed(collectionSlug string, eventHandler func(itemListedEvent any))

+ func (s *OSStreamWatcher) OnItemMetadataUpdated(collectionSlug string, eventHandler func(itemMetadataUpdatedEvent any))

+ func (s *OSStreamWatcher) OnItemReceivedBid(collectionSlug string, eventHandler func(itemReceivedBidEvent any))

+ func (s *OSStreamWatcher) OnItemReceivedOffer(collectionSlug string, eventHandler func(itemReceivedOfferEvent any))

+ func (s *OSStreamWatcher) SubscribeToListingsFor(slug string)

+ type StreamEventType string

+ const Listed

+ const MetadataUpdated

+ const ReceivedBid

+ const ReceivedOffer