@@ -18,7 +18,9 @@ namespace Akka.Streams.Stage
18
18
/// <typeparam name="TOut">TBD</typeparam>
19
19
internal class PushPullGraphLogic < TIn , TOut > : GraphStageLogic , IDetachedContext < TOut >
20
20
{
21
+ #pragma warning disable CS0618 // Type or member is obsolete
21
22
private AbstractStage < TIn , TOut > _currentStage ;
23
+ #pragma warning restore CS0618 // Type or member is obsolete
22
24
private readonly FlowShape < TIn , TOut > _shape ;
23
25
24
26
/// <summary>
@@ -30,7 +32,9 @@ internal class PushPullGraphLogic<TIn, TOut> : GraphStageLogic, IDetachedContext
30
32
public PushPullGraphLogic (
31
33
FlowShape < TIn , TOut > shape ,
32
34
Attributes attributes ,
35
+ #pragma warning disable CS0618 // Type or member is obsolete
33
36
AbstractStage < TIn , TOut > stage )
37
+ #pragma warning restore CS0618 // Type or member is obsolete
34
38
: base ( shape )
35
39
{
36
40
Attributes = attributes ;
@@ -59,7 +63,9 @@ public PushPullGraphLogic(
59
63
/// <summary>
60
64
/// TBD
61
65
/// </summary>
66
+ #pragma warning disable CS0618 // Type or member is obsolete
62
67
public AbstractStage < TIn , TOut > Stage { get ; }
68
+ #pragma warning restore CS0618 // Type or member is obsolete
63
69
64
70
IMaterializer ILifecycleContext . Materializer => Materializer ;
65
71
@@ -283,7 +289,9 @@ private void OnSupervision(Exception exception)
283
289
case Directive . Restart :
284
290
ResetAfterSupervise ( ) ;
285
291
_currentStage . PostStop ( ) ;
292
+ #pragma warning disable CS0618 // Type or member is obsolete
286
293
_currentStage = ( AbstractStage < TIn , TOut > ) _currentStage . Restart ( ) ;
294
+ #pragma warning restore CS0618 // Type or member is obsolete
287
295
_currentStage . PreStart ( Context ) ;
288
296
break ;
289
297
default :
@@ -316,14 +324,18 @@ public class PushPullGraphStageWithMaterializedValue<TIn, TOut, TMat> : GraphSta
316
324
/// <summary>
317
325
/// TBD
318
326
/// </summary>
327
+ #pragma warning disable CS0618 // Type or member is obsolete
319
328
public readonly Func < Attributes , ( IStage < TIn , TOut > , TMat ) > Factory ;
329
+ #pragma warning restore CS0618 // Type or member is obsolete
320
330
321
331
/// <summary>
322
332
/// TBD
323
333
/// </summary>
324
334
/// <param name="factory">TBD</param>
325
335
/// <param name="stageAttributes">TBD</param>
336
+ #pragma warning disable CS0618 // Type or member is obsolete
326
337
public PushPullGraphStageWithMaterializedValue ( Func < Attributes , ( IStage < TIn , TOut > , TMat ) > factory , Attributes stageAttributes )
338
+ #pragma warning restore CS0618 // Type or member is obsolete
327
339
{
328
340
InitialAttributes = stageAttributes ;
329
341
Factory = factory ;
@@ -350,10 +362,12 @@ public PushPullGraphStageWithMaterializedValue(Func<Attributes, (IStage<TIn, TOu
350
362
public override ILogicAndMaterializedValue < TMat > CreateLogicAndMaterializedValue ( Attributes inheritedAttributes )
351
363
{
352
364
var stageAndMat = Factory ( inheritedAttributes ) ;
365
+ #pragma warning disable CS0618 // Type or member is obsolete
353
366
return
354
367
new LogicAndMaterializedValue < TMat > (
355
368
new PushPullGraphLogic < TIn , TOut > ( Shape , inheritedAttributes ,
356
369
( AbstractStage < TIn , TOut > ) stageAndMat . Item1 ) , stageAndMat . Item2 ) ;
370
+ #pragma warning restore CS0618 // Type or member is obsolete
357
371
}
358
372
359
373
/// <summary>
@@ -376,7 +390,9 @@ public class PushPullGraphStage<TIn, TOut> : PushPullGraphStageWithMaterializedV
376
390
/// <param name="factory">TBD</param>
377
391
/// <param name="stageAttributes">TBD</param>
378
392
/// <returns>TBD</returns>
393
+ #pragma warning disable CS0618 // Type or member is obsolete
379
394
public PushPullGraphStage ( Func < Attributes , IStage < TIn , TOut > > factory , Attributes stageAttributes ) : base ( attributes => ( factory ( attributes ) , NotUsed . Instance ) , stageAttributes )
395
+ #pragma warning restore CS0618 // Type or member is obsolete
380
396
{
381
397
}
382
398
}
0 commit comments