Class ReactiveMessageService

Reactive service for message operations that provides RxJS Observable streams

Implements

IReactiveMessageService

Index

Constructors

Methods

getLatestMessage getMessages$ streamAllMessages streamAllMessagesSentBy autoConfiguration

Constructors

constructor

new ReactiveMessageService(
messagesService: IMessagesService,
): ReactiveMessageService
Parameters
- messagesService: IMessagesService
Returns ReactiveMessageService
- Defined in services/messages/reactive-message-service/ReactiveMessageService.ts:21

Methods

getLatestMessage

getLatestMessage(
params: GetAllMessagesParams,
): Observable<undefined | Partial<FullArweaveTransaction>>
Gets the latest message matching the given filters
Parameters
- params: GetAllMessagesParams
  Parameters for filtering messages
Returns Observable<undefined | Partial<FullArweaveTransaction>>
Observable that emits a single message or undefined if none found
Implementation of IReactiveMessageService.getLatestMessage
- Defined in services/messages/reactive-message-service/ReactiveMessageService.ts:46

getMessages$

getMessages$(
params: GetLatestMessagesParams,
): Observable<GetLatestMessagesResponse>
Fetches messages with the given parameters (single page, no cursor)
Parameters
- params: GetLatestMessagesParams
  Parameters for filtering messages
Returns Observable<GetLatestMessagesResponse>
Observable that emits a single GetLatestMessagesResponse
Implementation of IReactiveMessageService.getMessages$
- Defined in services/messages/reactive-message-service/ReactiveMessageService.ts:71

streamAllMessages

streamAllMessages(
params: GetAllMessagesParams,
): Observable<Partial<FullArweaveTransaction>[]>
Streams all messages matching the given filters as they are fetched
Parameters
- params: GetAllMessagesParams
  Parameters for filtering messages
Returns Observable<Partial<FullArweaveTransaction>[]>
Observable that emits arrays of messages as they are fetched
Implementation of IReactiveMessageService.streamAllMessages
- Defined in services/messages/reactive-message-service/ReactiveMessageService.ts:35

streamAllMessagesSentBy

streamAllMessagesSentBy(
params: GetAllMessagesBySenderParams,
): Observable<Partial<FullArweaveTransaction>[]>
Streams all messages sent by a specific address
Parameters
- params: GetAllMessagesBySenderParams
  Parameters for filtering messages, including required sender ID
Returns Observable<Partial<FullArweaveTransaction>[]>
Observable that emits arrays of messages as they are fetched
Implementation of IReactiveMessageService.streamAllMessagesSentBy
- Defined in services/messages/reactive-message-service/ReactiveMessageService.ts:39

`Static`autoConfiguration

autoConfiguration(): ReactiveMessageService
Creates a pre-configured instance of ReactiveMessageService

Returns ReactiveMessageService
A pre-configured ReactiveMessageService instance
- Defined in services/messages/reactive-message-service/ReactiveMessageService.ts:29