@@ -39,6 +39,12 @@ protected override void OnCompletedCore() { }
39
39
protected override void OnErrorCore ( System . Exception error ) { }
40
40
protected override void OnNextCore ( T value ) { }
41
41
}
42
+ public abstract class EventPatternSourceBase < TSender , TEventArgs >
43
+ {
44
+ protected EventPatternSourceBase ( System . IObservable < System . Reactive . EventPattern < TSender , TEventArgs > > source , System . Action < System . Action < TSender , TEventArgs > , System . Reactive . EventPattern < TSender , TEventArgs > > invokeHandler ) { }
45
+ protected void Add ( System . Delegate handler , System . Action < TSender , TEventArgs > invoke ) { }
46
+ protected void Remove ( System . Delegate handler ) { }
47
+ }
42
48
public class EventPattern < TEventArgs > : System . Reactive . EventPattern < object , TEventArgs >
43
49
{
44
50
public EventPattern ( object sender , TEventArgs e ) { }
@@ -51,28 +57,24 @@ public EventPattern(TSender sender, TEventArgs e) { }
51
57
public bool Equals ( System . Reactive . EventPattern < TSender , TEventArgs > other ) { }
52
58
public override bool Equals ( object obj ) { }
53
59
public override int GetHashCode ( ) { }
54
- }
55
- public abstract class EventPatternSourceBase < TSender , TEventArgs >
56
- {
57
- protected EventPatternSourceBase ( System . IObservable < System . Reactive . EventPattern < TSender , TEventArgs > > source , System . Action < System . Action < TSender , TEventArgs > , System . Reactive . EventPattern < TSender , TEventArgs > > invokeHandler ) { }
58
- protected void Add ( System . Delegate handler , System . Action < TSender , TEventArgs > invoke ) { }
59
- protected void Remove ( System . Delegate handler ) { }
60
+ public static bool == ( System . Reactive. EventPattern< TSender, TEventArgs > first, System . Reactive. EventPattern< TSender, TEventArgs > second) { }
61
+ public static bool != ( System . Reactive. EventPattern< TSender, TEventArgs > first, System . Reactive. EventPattern< TSender, TEventArgs > second) { }
60
62
}
61
63
[ System . AttributeUsageAttribute ( System . AttributeTargets . Assembly | System . AttributeTargets . Module | System . AttributeTargets . Class | System . AttributeTargets . Struct | System . AttributeTargets . Enum | System . AttributeTargets . Constructor | System . AttributeTargets . Method | System . AttributeTargets . Property | System . AttributeTargets . Field | System . AttributeTargets . Event | System . AttributeTargets . Interface | System . AttributeTargets . Parameter | System . AttributeTargets . Delegate | System . AttributeTargets . ReturnValue | System . AttributeTargets . GenericParameter | System . AttributeTargets . All ) ]
62
64
[ System . Reactive . ExperimentalAttribute ( ) ]
63
65
public sealed class ExperimentalAttribute : System . Attribute
64
66
{
65
67
public ExperimentalAttribute ( ) { }
66
68
}
69
+ public interface IEventPatternSource < TEventArgs >
70
+ {
71
+ public event System . EventHandler < TEventArgs > OnNext ;
72
+ }
67
73
public interface IEventPattern < out TSender , out TEventArgs >
68
74
{
69
75
TEventArgs EventArgs { get ; }
70
76
TSender Sender { get ; }
71
77
}
72
- public interface IEventPatternSource < TEventArgs >
73
- {
74
- public event System . EventHandler < TEventArgs > OnNext ;
75
- }
76
78
public interface IEventSource < out T >
77
79
{
78
80
public event System . Action < T > OnNext ;
@@ -83,16 +85,16 @@ public interface IObserver<in TValue, out TResult>
83
85
TResult OnError ( System . Exception exception ) ;
84
86
TResult OnNext ( TValue value ) ;
85
87
}
86
- [ System . Runtime . CompilerServices . AsyncMethodBuilderAttribute ( typeof ( System . Runtime . CompilerServices . TaskObservableMethodBuilder < > ) ) ]
87
- public interface ITaskObservable < out T > : System . IObservable < T >
88
- {
89
- System . Reactive . ITaskObservableAwaiter < T > GetAwaiter ( ) ;
90
- }
91
88
public interface ITaskObservableAwaiter < out T > : System . Runtime . CompilerServices . INotifyCompletion
92
89
{
93
90
bool IsCompleted { get ; }
94
91
T GetResult ( ) ;
95
92
}
93
+ [ System . Runtime . CompilerServices . AsyncMethodBuilderAttribute ( typeof ( System . Runtime . CompilerServices . TaskObservableMethodBuilder < T > ) ) ]
94
+ public interface ITaskObservable < out T > : System . IObservable < T >
95
+ {
96
+ System . Reactive . ITaskObservableAwaiter < T > GetAwaiter ( ) ;
97
+ }
96
98
[ System . Reactive . ExperimentalAttribute ( ) ]
97
99
public class ListObservable < T > : System . Collections . Generic . ICollection < T > , System . Collections . Generic . IEnumerable < T > , System . Collections . Generic . IList < T > , System . Collections . IEnumerable , System . IObservable < object >
98
100
{
@@ -118,9 +120,15 @@ public static System.Reactive.Notification<T> CreateOnCompleted<T>() { }
118
120
public static System . Reactive . Notification < T > CreateOnError < T > ( System . Exception error ) { }
119
121
public static System . Reactive . Notification < T > CreateOnNext < T > ( T value ) { }
120
122
}
123
+ public enum NotificationKind
124
+ {
125
+ OnNext = 0 ,
126
+ OnError = 1 ,
127
+ OnCompleted = 2 ,
128
+ }
121
129
public abstract class Notification < T > : System . IEquatable < System . Reactive . Notification < T > >
122
130
{
123
- protected internal Notification ( ) { }
131
+ protected Notification ( ) { }
124
132
public abstract System . Exception Exception { get ; }
125
133
public abstract bool HasValue { get ; }
126
134
public abstract System . Reactive . NotificationKind Kind { get ; }
@@ -133,12 +141,8 @@ protected internal Notification() { }
133
141
public override bool Equals ( object obj ) { }
134
142
public System . IObservable < T > ToObservable ( ) { }
135
143
public System . IObservable < T > ToObservable ( System . Reactive . Concurrency . IScheduler scheduler ) { }
136
- }
137
- public enum NotificationKind
138
- {
139
- OnNext = 0 ,
140
- OnError = 1 ,
141
- OnCompleted = 2 ,
144
+ public static bool == ( System . Reactive. Notification< T> left, System . Reactive. Notification< T> right) { }
145
+ public static bool != ( System . Reactive. Notification< T> left, System . Reactive. Notification< T> right) { }
142
146
}
143
147
public abstract class ObservableBase < T > : System . IObservable < T >
144
148
{
@@ -187,6 +191,8 @@ public bool Equals(System.Reactive.TimeInterval<T> other) { }
187
191
public override bool Equals ( object obj ) { }
188
192
public override int GetHashCode ( ) { }
189
193
public override string ToString ( ) { }
194
+ public static bool == ( System . Reactive. TimeInterval< T> first, System . Reactive. TimeInterval< T> second) { }
195
+ public static bool != ( System . Reactive. TimeInterval< T> first, System . Reactive. TimeInterval< T> second) { }
190
196
}
191
197
public class static Timestamped
192
198
{
@@ -201,6 +207,8 @@ public bool Equals(System.Reactive.Timestamped<T> other) { }
201
207
public override bool Equals ( object obj ) { }
202
208
public override int GetHashCode ( ) { }
203
209
public override string ToString ( ) { }
210
+ public static bool == ( System . Reactive. Timestamped< T> first, System . Reactive. Timestamped< T> second) { }
211
+ public static bool != ( System . Reactive. Timestamped< T> first, System . Reactive. Timestamped< T> second) { }
204
212
}
205
213
public struct Unit : System . IEquatable < System . Reactive . Unit >
206
214
{
@@ -209,6 +217,8 @@ public bool Equals(System.Reactive.Unit other) { }
209
217
public override bool Equals ( object obj ) { }
210
218
public override int GetHashCode ( ) { }
211
219
public override string ToString ( ) { }
220
+ public static bool == ( System . Reactive. Unit first, System . Reactive. Unit second) { }
221
+ public static bool != ( System . Reactive. Unit first, System . Reactive. Unit second) { }
212
222
}
213
223
}
214
224
namespace System . Reactive . Concurrency
@@ -295,12 +305,6 @@ public interface IConcurrencyAbstractionLayer
295
305
void StartThread ( System . Action < object > action , object state ) ;
296
306
System . IDisposable StartTimer ( System . Action < object > action , object state , System . TimeSpan dueTime ) ;
297
307
}
298
- public sealed class ImmediateScheduler : System . Reactive . Concurrency . LocalScheduler
299
- {
300
- public static System . Reactive . Concurrency . ImmediateScheduler Instance { get ; }
301
- public override System . IDisposable Schedule < TState > ( TState state , System . Func < System . Reactive . Concurrency . IScheduler , TState , System . IDisposable > action ) { }
302
- public override System . IDisposable Schedule < TState > ( TState state , System . TimeSpan dueTime , System . Func < System . Reactive . Concurrency . IScheduler , TState , System . IDisposable > action ) { }
303
- }
304
308
public interface IScheduledItem< TAbsolute>
305
309
{
306
310
TAbsolute DueTime { get ; }
@@ -329,6 +333,12 @@ public interface IStopwatchProvider
329
333
{
330
334
System . Reactive . Concurrency . IStopwatch StartStopwatch ( ) ;
331
335
}
336
+ public sealed class ImmediateScheduler : System. Reactive. Concurrency. LocalScheduler
337
+ {
338
+ public static System . Reactive . Concurrency . ImmediateScheduler Instance { get ; }
339
+ public override System . IDisposable Schedule < TState > ( TState state , System . Func < System . Reactive . Concurrency . IScheduler , TState , System . IDisposable > action ) { }
340
+ public override System . IDisposable Schedule < TState > ( TState state , System . TimeSpan dueTime , System . Func < System . Reactive . Concurrency . IScheduler , TState , System . IDisposable > action ) { }
341
+ }
332
342
public abstract class LocalScheduler : System. IServiceProvider, System. Reactive. Concurrency. IScheduler, System. Reactive. Concurrency. IStopwatchProvider
333
343
{
334
344
protected LocalScheduler ( ) { }
@@ -350,7 +360,7 @@ public System.IDisposable SchedulePeriodic<TState>(TState state, System.TimeSpan
350
360
public override System . Reactive . Concurrency . IStopwatch StartStopwatch ( ) { }
351
361
}
352
362
public abstract class ScheduledItem< TAbsolute> : System. IComparable< System. Reactive. Concurrency. ScheduledItem< TAbsolute>> , System. IDisposable, System. Reactive. Concurrency. IScheduledItem< TAbsolute>
353
- where TAbsolute : System . IComparable < >
363
+ where TAbsolute : System . IComparable < TAbsolute >
354
364
{
355
365
protected ScheduledItem ( TAbsolute dueTime, System . Collections. Generic. IComparer< TAbsolute> comparer) { }
356
366
public TAbsolute DueTime { get ; }
@@ -361,9 +371,15 @@ public override bool Equals(object obj) { }
361
371
public override int GetHashCode ( ) { }
362
372
public void Invoke ( ) { }
363
373
protected abstract System . IDisposable InvokeCore ( ) ;
374
+ public static bool == ( System . Reactive. Concurrency. ScheduledItem< TAbsolute> left, System . Reactive. Concurrency. ScheduledItem< TAbsolute> right) { }
375
+ public static bool > ( System . Reactive. Concurrency. ScheduledItem< TAbsolute> left, System . Reactive. Concurrency. ScheduledItem< TAbsolute> right) { }
376
+ public static bool > = ( System . Reactive. Concurrency. ScheduledItem< TAbsolute> left, System . Reactive. Concurrency. ScheduledItem< TAbsolute> right) { }
377
+ public static bool != ( System . Reactive. Concurrency. ScheduledItem< TAbsolute> left, System . Reactive. Concurrency. ScheduledItem< TAbsolute> right) { }
378
+ public static bool < ( System . Reactive. Concurrency. ScheduledItem< TAbsolute> left, System . Reactive. Concurrency. ScheduledItem< TAbsolute> right) { }
379
+ public static bool < = ( System . Reactive. Concurrency. ScheduledItem< TAbsolute> left, System . Reactive. Concurrency. ScheduledItem< TAbsolute> right) { }
364
380
}
365
381
public sealed class ScheduledItem< TAbsolute, TValue> : System. Reactive. Concurrency. ScheduledItem< TAbsolute>
366
- where TAbsolute : System . IComparable < >
382
+ where TAbsolute : System . IComparable < TAbsolute >
367
383
{
368
384
public ScheduledItem ( System . Reactive. Concurrency. IScheduler scheduler, TValue state, System . Func< System. Reactive. Concurrency. IScheduler, TValue , System . IDisposable> action, TAbsolute dueTime, System . Collections. Generic. IComparer< TAbsolute> comparer) { }
369
385
public ScheduledItem ( System . Reactive. Concurrency. IScheduler scheduler, TValue state, System . Func< System. Reactive. Concurrency. IScheduler, TValue , System . IDisposable> action, TAbsolute dueTime) { }
@@ -438,7 +454,7 @@ public void GetResult() { }
438
454
public void OnCompleted ( System . Action continuation ) { }
439
455
}
440
456
public class SchedulerQueue< TAbsolute>
441
- where TAbsolute : System . IComparable < >
457
+ where TAbsolute : System . IComparable < TAbsolute >
442
458
{
443
459
public SchedulerQueue ( ) { }
444
460
public SchedulerQueue ( int capacity) { }
@@ -483,16 +499,8 @@ public System.IDisposable ScheduleLongRunning<TState>(TState state, System.Actio
483
499
public System . IDisposable SchedulePeriodic < TState > ( TState state , System . TimeSpan period , System . Func < TState , TState > action ) { }
484
500
public override System . Reactive . Concurrency . IStopwatch StartStopwatch ( ) { }
485
501
}
486
- public abstract class VirtualTimeScheduler < TAbsolute , TRelative > : System . Reactive . Concurrency . VirtualTimeSchedulerBase < TAbsolute , TRelative >
487
- where TAbsolute : System . IComparable < >
488
- {
489
- protected VirtualTimeScheduler ( ) { }
490
- protected VirtualTimeScheduler ( TAbsolute initialClock , System . Collections . Generic . IComparer < TAbsolute > comparer ) { }
491
- protected override System . Reactive . Concurrency . IScheduledItem < TAbsolute > GetNext ( ) { }
492
- public override System . IDisposable ScheduleAbsolute < TState > ( TState state , TAbsolute dueTime , System . Func < System . Reactive . Concurrency . IScheduler , TState , System . IDisposable > action ) { }
493
- }
494
502
public abstract class VirtualTimeSchedulerBase < TAbsolute , TRelative > : System . IServiceProvider , System . Reactive . Concurrency . IScheduler , System . Reactive . Concurrency . IStopwatchProvider
495
- where TAbsolute : System . IComparable < >
503
+ where TAbsolute : System . IComparable < TAbsolute >
496
504
{
497
505
protected VirtualTimeSchedulerBase ( ) { }
498
506
protected VirtualTimeSchedulerBase ( TAbsolute initialClock , System . Collections . Generic . IComparer < TAbsolute > comparer ) { }
@@ -520,9 +528,17 @@ public void Stop() { }
520
528
public class static VirtualTimeSchedulerExtensions
521
529
{
522
530
public static System . IDisposable ScheduleAbsolute < TAbsolute , TRelative > ( this System . Reactive . Concurrency . VirtualTimeSchedulerBase < TAbsolute , TRelative > scheduler , TAbsolute dueTime , System . Action action )
523
- where TAbsolute : System . IComparable < > { }
531
+ where TAbsolute : System . IComparable < TAbsolute > { }
524
532
public static System . IDisposable ScheduleRelative < TAbsolute , TRelative > ( this System . Reactive . Concurrency . VirtualTimeSchedulerBase < TAbsolute , TRelative > scheduler , TRelative dueTime , System . Action action )
525
- where TAbsolute : System . IComparable < > { }
533
+ where TAbsolute : System . IComparable < TAbsolute > { }
534
+ }
535
+ public abstract class VirtualTimeScheduler < TAbsolute , TRelative > : System . Reactive . Concurrency . VirtualTimeSchedulerBase < TAbsolute , TRelative >
536
+ where TAbsolute : System . IComparable < TAbsolute >
537
+ {
538
+ protected VirtualTimeScheduler ( ) { }
539
+ protected VirtualTimeScheduler ( TAbsolute initialClock , System . Collections . Generic . IComparer < TAbsolute > comparer ) { }
540
+ protected override System . Reactive . Concurrency . IScheduledItem < TAbsolute > GetNext ( ) { }
541
+ public override System . IDisposable ScheduleAbsolute < TState > ( TState state , TAbsolute dueTime , System . Func < System . Reactive . Concurrency . IScheduler , TState , System . IDisposable > action ) { }
526
542
}
527
543
}
528
544
namespace System . Reactive . Disposables
@@ -822,11 +838,11 @@ public interface IQbservable
822
838
System . Linq . Expressions . Expression Expression { get ; }
823
839
System . Reactive . Linq . IQbservableProvider Provider { get ; }
824
840
}
825
- public interface IQbservable < out T > : System . IObservable < T > , System . Reactive . Linq . IQbservable { }
826
841
public interface IQbservableProvider
827
842
{
828
843
System . Reactive . Linq . IQbservable < TResult > CreateQuery < TResult > ( System . Linq . Expressions . Expression expression ) ;
829
844
}
845
+ public interface IQbservable < out T > : System . IObservable < T > , System . Reactive . Linq . IQbservable { }
830
846
[ System . AttributeUsageAttribute ( System . AttributeTargets . Class | System . AttributeTargets . All , Inherited = false ) ]
831
847
public sealed class LocalQueryMethodImplementationTypeAttribute : System . Attribute
832
848
{
@@ -2469,17 +2485,6 @@ public static System.Reactive.Subjects.ISubject<TSource> Synchronize<TSource>(Sy
2469
2485
public static System . Reactive . Subjects . ISubject < TSource , TResult > Synchronize < TSource , TResult > ( System . Reactive . Subjects . ISubject < TSource , TResult > subject , System . Reactive . Concurrency . IScheduler scheduler ) { }
2470
2486
public static System . Reactive . Subjects . ISubject < TSource > Synchronize < TSource > ( System . Reactive . Subjects . ISubject < TSource > subject , System . Reactive . Concurrency . IScheduler scheduler ) { }
2471
2487
}
2472
- public sealed class Subject < T > : System . Reactive . Subjects . SubjectBase < T >
2473
- {
2474
- public Subject ( ) { }
2475
- public override bool HasObservers { get ; }
2476
- public override bool IsDisposed { get ; }
2477
- public override void Dispose ( ) { }
2478
- public override void OnCompleted ( ) { }
2479
- public override void OnError ( System . Exception error ) { }
2480
- public override void OnNext ( T value ) { }
2481
- public override System . IDisposable Subscribe ( System . IObserver < T > observer ) { }
2482
- }
2483
2488
public abstract class SubjectBase < T > : System . IDisposable , System . IObservable < T > , System . IObserver < T > , System . Reactive . Subjects . ISubject < T > , System . Reactive . Subjects . ISubject < T , T >
2484
2489
{
2485
2490
protected SubjectBase ( ) { }
@@ -2491,6 +2496,17 @@ protected SubjectBase() { }
2491
2496
public abstract void OnNext ( T value ) ;
2492
2497
public abstract System . IDisposable Subscribe ( System . IObserver < T > observer ) ;
2493
2498
}
2499
+ public sealed class Subject < T > : System . Reactive . Subjects . SubjectBase < T >
2500
+ {
2501
+ public Subject ( ) { }
2502
+ public override bool HasObservers { get ; }
2503
+ public override bool IsDisposed { get ; }
2504
+ public override void Dispose ( ) { }
2505
+ public override void OnCompleted ( ) { }
2506
+ public override void OnError ( System . Exception error ) { }
2507
+ public override void OnNext ( T value ) { }
2508
+ public override System . IDisposable Subscribe ( System . IObserver < T > observer ) { }
2509
+ }
2494
2510
}
2495
2511
namespace System . Reactive . Threading . Tasks
2496
2512
{
0 commit comments