1010using Android . Views ;
1111using Android . Widget ;
1212
13+ namespace RX . Internal . Operators
14+ {
15+ partial class OnSubscribeDoOnEach
16+ {
17+ public void Call ( Java . Lang . Object p1 )
18+ {
19+ Call ( ( global ::RX . Subscriber ) p1 ) ;
20+ }
21+ }
22+
23+ partial class CompletableFlatMapSingleToCompletable
24+ {
25+ public void Call ( Java . Lang . Object p1 )
26+ {
27+ Call ( ( global ::RX . ICompletableSubscriber ) p1 ) ;
28+ }
29+ }
30+
31+ partial class SingleFromFuture
32+ {
33+ public void Call ( Java . Lang . Object p1 )
34+ {
35+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
36+ }
37+ }
38+
39+ partial class OnSubscribeFlatMapSingle
40+ {
41+ public void Call ( Java . Lang . Object p1 )
42+ {
43+ Call ( ( global ::RX . Subscriber ) p1 ) ;
44+ }
45+ }
46+
47+ partial class OnSubscribeFlatMapCompletable
48+ {
49+ public void Call ( Java . Lang . Object p1 )
50+ {
51+ Call ( ( global ::RX . Subscriber ) p1 ) ;
52+ }
53+ }
54+
55+ partial class SingleFromObservable
56+ {
57+ public void Call ( Java . Lang . Object p1 )
58+ {
59+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
60+ }
61+ }
62+
63+ partial class SingleLiftObservableOperator
64+ {
65+ public void Call ( Java . Lang . Object p1 )
66+ {
67+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
68+ }
69+ }
70+
71+ partial class OnSubscribeCreate
72+ {
73+ public void Call ( Java . Lang . Object p1 )
74+ {
75+ Call ( ( global ::RX . Subscriber ) p1 ) ;
76+ }
77+ }
78+
79+ partial class SingleObserveOn
80+ {
81+ public void Call ( Java . Lang . Object p1 )
82+ {
83+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
84+ }
85+ }
86+
87+ partial class CompletableFromEmitter
88+ {
89+ public void Call ( Java . Lang . Object p1 )
90+ {
91+ Call ( ( global ::RX . ICompletableSubscriber ) p1 ) ;
92+ }
93+ }
94+
95+ partial class SingleOnErrorReturn
96+ {
97+ public void Call ( Java . Lang . Object p1 )
98+ {
99+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
100+ }
101+ }
102+
103+ partial class SingleTakeUntilCompletable
104+ {
105+ public void Call ( Java . Lang . Object p1 )
106+ {
107+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
108+ }
109+ }
110+
111+ partial class SingleTakeUntilObservable
112+ {
113+ public void Call ( Java . Lang . Object p1 )
114+ {
115+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
116+ }
117+ }
118+
119+ partial class SingleTakeUntilSingle
120+ {
121+ public void Call ( Java . Lang . Object p1 )
122+ {
123+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
124+ }
125+ }
126+
127+ partial class SingleTimeout
128+ {
129+ public void Call ( Java . Lang . Object p1 )
130+ {
131+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
132+ }
133+ }
134+
135+ partial class SingleToObservable
136+ {
137+ public void Call ( Java . Lang . Object p1 )
138+ {
139+ Call ( ( global ::RX . Subscriber ) p1 ) ;
140+ }
141+ }
142+
143+ partial class SingleFromEmitter
144+ {
145+ public void Call ( Java . Lang . Object p1 )
146+ {
147+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
148+ }
149+ }
150+
151+ partial class SingleFromCallable
152+ {
153+
154+ public void Call ( Java . Lang . Object p1 )
155+ {
156+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
157+ }
158+ }
159+
160+ partial class SingleDoOnUnsubscribe
161+ {
162+
163+ public void Call ( Java . Lang . Object p1 )
164+ {
165+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
166+ }
167+ }
168+
169+ partial class OnSubscribeToMultimap : RX . Functions . IFunc0
170+ {
171+ public Java . Lang . Object Call ( )
172+ {
173+ return ( Java . Lang . Object ) CallX ( ) ;
174+ }
175+
176+ public void Call ( Java . Lang . Object p1 )
177+ {
178+ Call ( ( global ::RX . Subscriber ) p1 ) ;
179+ }
180+ }
181+
182+ partial class SingleDoOnSubscribe
183+ {
184+ public void Call ( Java . Lang . Object p1 )
185+ {
186+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
187+ }
188+ }
189+
190+ partial class OnSubscribeToMap : RX . Functions . IFunc0
191+ {
192+ public Java . Lang . Object Call ( )
193+ {
194+ return ( Java . Lang . Object ) CallX ( ) ;
195+ }
196+
197+ public void Call ( Java . Lang . Object p1 )
198+ {
199+ Call ( ( global ::RX . Subscriber ) p1 ) ;
200+ }
201+ }
202+
203+ partial class SingleDoOnEvent
204+ {
205+ public void Call ( Java . Lang . Object p1 )
206+ {
207+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
208+ }
209+ }
210+
211+ partial class OnSubscribeSwitchIfEmpty
212+ {
213+ public void Call ( Java . Lang . Object p1 )
214+ {
215+ Call ( ( global ::RX . Subscriber ) p1 ) ;
216+ }
217+ }
218+
219+ partial class SingleDelay
220+ {
221+ public void Call ( Java . Lang . Object p1 )
222+ {
223+ Call ( ( global ::RX . SingleSubscriber ) p1 ) ;
224+ }
225+ }
226+
227+ partial class OnSubscribeSkipTimed
228+ {
229+ public void Call ( Java . Lang . Object p1 )
230+ {
231+ Call ( ( global ::RX . Subscriber ) p1 ) ;
232+ }
233+ }
234+ }
235+
13236namespace RX . Observables
14237{
15238 partial class AsyncOnSubscribe
@@ -44,7 +267,7 @@ partial class CompletableOnSubscribeConcat
44267 {
45268 public unsafe void Call ( Java . Lang . Object p0 )
46269 {
47- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
270+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
48271 }
49272 }
50273
@@ -68,15 +291,15 @@ partial class CompletableOnSubscribeMergeIterable
68291 {
69292 public unsafe void Call ( Java . Lang . Object p0 )
70293 {
71- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
294+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
72295 }
73296 }
74297
75298 partial class CompletableOnSubscribeTimeout
76299 {
77300 public unsafe void Call ( Java . Lang . Object p0 )
78301 {
79- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
302+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
80303 }
81304 }
82305
@@ -92,47 +315,47 @@ partial class CompletableOnSubscribeConcatArray
92315 {
93316 public unsafe void Call ( Java . Lang . Object p0 )
94317 {
95- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
318+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
96319 }
97320 }
98321
99322 partial class CompletableOnSubscribeMergeArray
100323 {
101324 public unsafe void Call ( Java . Lang . Object p0 )
102325 {
103- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
326+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
104327 }
105328 }
106329
107330 partial class CompletableOnSubscribeMergeDelayErrorArray
108331 {
109332 public unsafe void Call ( Java . Lang . Object p0 )
110333 {
111- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
334+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
112335 }
113336 }
114337
115338 partial class CompletableOnSubscribeConcatIterable
116339 {
117340 public unsafe void Call ( Java . Lang . Object p0 )
118341 {
119- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
342+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
120343 }
121344 }
122345
123346 partial class CompletableOnSubscribeMerge
124347 {
125348 public unsafe void Call ( Java . Lang . Object p0 )
126349 {
127- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
350+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
128351 }
129352 }
130353
131354 partial class CompletableOnSubscribeMergeDelayErrorIterable
132355 {
133356 public unsafe void Call ( Java . Lang . Object p0 )
134357 {
135- Call ( ( RX . Completable . ICompletableSubscriber ) p0 ) ;
358+ Call ( ( RX . ICompletableSubscriber ) p0 ) ;
136359 }
137360 }
138361
@@ -478,9 +701,10 @@ public Java.Lang.Object Call(Java.Lang.Object p0)
478701 {
479702 return Call ( ( RX . Subscriber ) p0 ) ;
480703 }
704+
481705 public Java . Lang . Object Call ( Java . Lang . Object p0 , Java . Lang . Object p1 )
482706 {
483- return TryCall ( p0 , p1 ) ;
707+ return CallX ( p0 , p1 ) ;
484708 }
485709 }
486710
@@ -1083,50 +1307,4 @@ public unsafe void Call(Java.Lang.Object p0)
10831307 Call ( ( RX . Subscriber ) p0 ) ;
10841308 }
10851309 }
1086- }
1087-
1088- namespace RX . Internal . Util . Unsafe
1089- {
1090- partial class ConcurrentCircularArrayQueueL0Pad
1091- {
1092- internal static IntPtr java_class_handle ;
1093- internal static IntPtr class_ref
1094- {
1095- get
1096- {
1097- return JNIEnv . FindClass ( "rx/internal/util/unsafe/ConcurrentCircularArrayQueueL0Pad" , ref java_class_handle ) ;
1098- }
1099- }
1100-
1101- protected override IntPtr ThresholdClass
1102- {
1103- get { return class_ref ; }
1104- }
1105-
1106- protected override global ::System . Type ThresholdType
1107- {
1108- get { return typeof ( ConcurrentCircularArrayQueueL0Pad ) ; }
1109- }
1110- }
1111- partial class BaseLinkedQueuePad0
1112- {
1113- internal static IntPtr java_class_handle ;
1114- internal static IntPtr class_ref
1115- {
1116- get
1117- {
1118- return JNIEnv . FindClass ( "rx/internal/util/unsafe/BaseLinkedQueuePad0" , ref java_class_handle ) ;
1119- }
1120- }
1121-
1122- protected override IntPtr ThresholdClass
1123- {
1124- get { return class_ref ; }
1125- }
1126-
1127- protected override global ::System . Type ThresholdType
1128- {
1129- get { return typeof ( BaseLinkedQueuePad0 ) ; }
1130- }
1131- }
11321310}
0 commit comments