@@ -6,25 +6,25 @@ namespace Open.Database.Extensions;
66
77public static partial class ChannelDbExtensions
88{
9- internal static Channel < T > CreateChannel < T > ( int capacity = - 1 , bool singleReader = false , bool singleWriter = true )
10- {
11- if ( capacity == 0 ) throw new ArgumentOutOfRangeException ( nameof ( capacity ) , capacity , "Cannot be zero." ) ;
12- if ( capacity < - 1 ) throw new ArgumentOutOfRangeException ( nameof ( capacity ) , capacity , "Must greater than zero or equal to negative one (unbounded)." ) ;
9+ internal static Channel < T > CreateChannel < T > ( int capacity = - 1 , bool singleReader = false , bool singleWriter = true )
10+ {
11+ if ( capacity == 0 ) throw new ArgumentOutOfRangeException ( nameof ( capacity ) , capacity , "Cannot be zero." ) ;
12+ if ( capacity < - 1 ) throw new ArgumentOutOfRangeException ( nameof ( capacity ) , capacity , "Must greater than zero or equal to negative one (unbounded)." ) ;
1313 Contract . EndContractBlock ( ) ;
1414
15- return capacity > 0
16- ? Channel . CreateBounded < T > ( new BoundedChannelOptions ( capacity )
17- {
18- SingleWriter = singleWriter ,
19- SingleReader = singleReader ,
20- AllowSynchronousContinuations = true ,
21- FullMode = BoundedChannelFullMode . Wait
22- } )
23- : Channel . CreateUnbounded < T > ( new UnboundedChannelOptions
24- {
25- SingleWriter = singleWriter ,
26- SingleReader = singleReader ,
27- AllowSynchronousContinuations = true
28- } ) ;
29- }
15+ return capacity > 0
16+ ? Channel . CreateBounded < T > ( new BoundedChannelOptions ( capacity )
17+ {
18+ SingleWriter = singleWriter ,
19+ SingleReader = singleReader ,
20+ AllowSynchronousContinuations = true ,
21+ FullMode = BoundedChannelFullMode . Wait
22+ } )
23+ : Channel . CreateUnbounded < T > ( new UnboundedChannelOptions
24+ {
25+ SingleWriter = singleWriter ,
26+ SingleReader = singleReader ,
27+ AllowSynchronousContinuations = true
28+ } ) ;
29+ }
3030}
0 commit comments