Skip to content

Commit

Permalink
alp[habetica
Browse files Browse the repository at this point in the history
  • Loading branch information
elee1766 committed Jan 15, 2024
1 parent 800dc9f commit c79c0aa
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion interface.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@ import "context"
type Stream[T any] interface {
Add(ctx context.Context, v T, idarg ...string) (string, error)
Key() string
Len(ctx context.Context) (int64, error)
Range(ctx context.Context, from, to string, count ...int64) ([]Message[T], error)
RevRange(ctx context.Context, from, to string, count ...int64) ([]Message[T], error)
Len(ctx context.Context) (int64, error)
}

// Consumer is a generic consumer interface
Expand Down

0 comments on commit c79c0aa

Please sign in to comment.