Interface IReactiveMessageService

Reactive interface for message service operations that provides RxJS Observable streams

interface IReactiveMessageService {
    getLatestMessage(
        params: GetAllMessagesParams,
    ): Observable<undefined | Partial<FullArweaveTransaction>>;
    streamAllMessages(
        params: GetAllMessagesParams,
    ): Observable<Partial<FullArweaveTransaction>[]>;
    streamAllMessagesSentBy(
        params: GetAllMessagesBySenderParams,
    ): Observable<Partial<FullArweaveTransaction>[]>;
}

Implemented by

ReactiveMessageService

Index

Methods

getLatestMessage streamAllMessages streamAllMessagesSentBy

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
- Defined in services/messages/reactive-message-service/abstract/IReactiveMessageService.ts:32

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
- Defined in services/messages/reactive-message-service/abstract/IReactiveMessageService.ts:18

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
- Defined in services/messages/reactive-message-service/abstract/IReactiveMessageService.ts:25