Fixes
This commit is contained in:
@@ -582,6 +582,7 @@ export class Convo {
|
|||||||
error?.retry()
|
error?.retry()
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
|
this.commit()
|
||||||
}
|
}
|
||||||
|
|
||||||
ingestFirehose(events: ChatBskyConvoGetLog.OutputSchema['logs']) {
|
ingestFirehose(events: ChatBskyConvoGetLog.OutputSchema['logs']) {
|
||||||
|
|||||||
@@ -44,11 +44,15 @@ export function ConvoProvider({
|
|||||||
const events = useMessagesEventBus()
|
const events = useMessagesEventBus()
|
||||||
|
|
||||||
React.useEffect(() => {
|
React.useEffect(() => {
|
||||||
const remove = events.trailConvo(convoId, events => {
|
const trail = events.trailConvo(convoId, events => {
|
||||||
convo.ingestFirehose(events)
|
convo.ingestFirehose(events)
|
||||||
})
|
})
|
||||||
|
const onConnect = events.onConnect(convo.onFirehoseConnect)
|
||||||
|
const onError = events.onError(convo.onFirehoseError)
|
||||||
return () => {
|
return () => {
|
||||||
remove()
|
trail()
|
||||||
|
onConnect()
|
||||||
|
onError()
|
||||||
}
|
}
|
||||||
}, [convoId, convo, events])
|
}, [convoId, convo, events])
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user