-
Notifications
You must be signed in to change notification settings - Fork 196
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat(block-logs-stream): add block logs stream package #1070
Conversation
🦋 Changeset detectedLatest commit: 4891d89 The changes in this PR will be included in the next version bump. This PR includes changesets to release 1 package
Not sure what this means? Click here to learn what changesets are. Click here if you're a maintainer who wants to add another changeset to this PR |
Current dependencies on/for this PR:
This comment was auto-generated by Graphite. |
d739e85
to
093a852
Compare
093a852
to
ca31d48
Compare
748f33c
to
1b417fa
Compare
704cb3b
to
51a7be0
Compare
This reverts commit 1952a98.
events, | ||
}), | ||
map(({ logs }) => from(groupLogsByBlockNumber(logs))), | ||
mergeAll() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should we add import { mergeAll } from "rxjs"
for this example?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
also what's the difference between map + mergeAll
to mergeMap
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
no real difference! just got here iteratively, can do mergeMap
instead
publicClient, | ||
address, | ||
events, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
is it worth adding the definitions of these to the example? or a comment about how to define them?
FetchLogsResult<TAbiEvents> | ||
>; | ||
|
||
export function blockRangeToLogs<TAbiEvents extends readonly AbiEvent[]>({ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should we add a code documentation comment above here that explains the purpose / behavior?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
minor comments, not blocking
Co-authored-by: alvarius <[email protected]>
just merged #1036 - can we add a changeset to this PR to try out the new release pipeline? |
pulled out of #1033