Skip to content

Commit

Permalink
Merge branch 'remove-streamresult' into project-unfolds
Browse files Browse the repository at this point in the history
  • Loading branch information
bartelink committed Aug 1, 2024
2 parents 31b8fb8 + b375d90 commit edd3004
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/Propulsion/Streams.fs
Original file line number Diff line number Diff line change
Expand Up @@ -1062,10 +1062,10 @@ module Dispatcher =
override _.TryReplenish(pending, handleStarted) = inner.TryReplenish(pending, handleStarted, project)
override _.InterpretProgress res = interpretProgress res


type ResProgressAndMetrics<'O> = (struct ('O * Buffer.HandlerProgress voption * StreamSpan.Metrics))
type ExnAndMetrics = (struct(exn * bool * StreamSpan.Metrics))
type NextIndexAndMetrics = (struct(int64 * StreamSpan.Metrics))

/// Implementation of IDispatcher that allows a supplied handler select work and declare completion based on arbitrarily defined criteria
type Batched<'F>
( select: Func<Scheduling.Item<'F> seq, Scheduling.Item<'F>[]>,
Expand Down

0 comments on commit edd3004

Please sign in to comment.