Skip to content

Commit 8580932

Browse files
AarononthewebAaronontheweb
authored
made transport adapter components public (#6838)
Needed for some work we're doing outside the main Akka.NET project
1 parent 54f4967 commit 8580932

File tree

3 files changed

+107
-7
lines changed

3 files changed

+107
-7
lines changed

‎src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveRemote.DotNet.verified.txt

+50
Original file line numberDiff line numberDiff line change
@@ -479,6 +479,18 @@ namespace Akka.Remote.Transport
479479
public override System.Threading.Tasks.Task<System.ValueTuple<Akka.Actor.Address, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.IAssociationEventListener>>> Listen() { }
480480
public override System.Threading.Tasks.Task<bool> Shutdown() { }
481481
}
482+
public abstract class AbstractTransportAdapterHandle : Akka.Remote.Transport.AssociationHandle
483+
{
484+
protected AbstractTransportAdapterHandle(Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
485+
protected AbstractTransportAdapterHandle(Akka.Actor.Address originalLocalAddress, Akka.Actor.Address originalRemoteAddress, Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
486+
public Akka.Actor.Address OriginalLocalAddress { get; }
487+
public Akka.Actor.Address OriginalRemoteAddress { get; }
488+
protected Akka.Remote.Transport.SchemeAugmenter SchemeAugmenter { get; }
489+
public Akka.Remote.Transport.AssociationHandle WrappedHandle { get; }
490+
protected bool Equals(Akka.Remote.Transport.AbstractTransportAdapterHandle other) { }
491+
public override bool Equals(object obj) { }
492+
public override int GetHashCode() { }
493+
}
482494
public abstract class Activity
483495
{
484496
protected Activity() { }
@@ -506,6 +518,17 @@ namespace Akka.Remote.Transport
506518
protected override System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> InterceptListen(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> listenerTask) { }
507519
public override System.Threading.Tasks.Task<bool> Shutdown() { }
508520
}
521+
public abstract class ActorTransportAdapterManager : Akka.Actor.UntypedActor
522+
{
523+
protected Akka.Remote.Transport.IAssociationEventListener AssociationListener;
524+
protected System.Collections.Generic.Queue<object> DelayedEvents;
525+
protected Akka.Actor.Address LocalAddress;
526+
protected long UniqueId;
527+
protected ActorTransportAdapterManager() { }
528+
protected long NextId() { }
529+
protected override void OnReceive(object message) { }
530+
protected abstract void Ready(object message);
531+
}
509532
public class AkkaProtocolException : Akka.Actor.AkkaException
510533
{
511534
public AkkaProtocolException(string message, System.Exception cause = null) { }
@@ -517,6 +540,12 @@ namespace Akka.Remote.Transport
517540
public Akka.Actor.Address LocalAddress { get; }
518541
public Akka.Actor.Address RemoteAddress { get; }
519542
}
543+
public sealed class AssociateUnderlying : Akka.Remote.Transport.TransportOperation
544+
{
545+
public AssociateUnderlying(Akka.Actor.Address remoteAddress, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> statusPromise) { }
546+
public Akka.Actor.Address RemoteAddress { get; }
547+
public System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> StatusPromise { get; }
548+
}
520549
public abstract class AssociationHandle
521550
{
522551
protected AssociationHandle(Akka.Actor.Address localAddress, Akka.Actor.Address remoteAddress) { }
@@ -568,6 +597,11 @@ namespace Akka.Remote.Transport
568597
Shutdown = 1,
569598
Quarantined = 2,
570599
}
600+
public sealed class DisassociateUnderlying : Akka.Remote.Transport.TransportOperation, Akka.Event.IDeadLetterSuppression
601+
{
602+
public DisassociateUnderlying(Akka.Remote.Transport.DisassociateInfo info = 0) { }
603+
public Akka.Remote.Transport.DisassociateInfo Info { get; }
604+
}
571605
public sealed class Disassociated : Akka.Actor.INoSerializationVerificationNeeded, Akka.Event.IDeadLetterSuppression, Akka.Remote.Transport.IHandleEvent
572606
{
573607
public Disassociated(Akka.Remote.Transport.DisassociateInfo info) { }
@@ -669,6 +703,17 @@ namespace Akka.Remote.Transport
669703
public ListenAttempt(Akka.Actor.Address boundAddress) { }
670704
public Akka.Actor.Address BoundAddress { get; }
671705
}
706+
public sealed class ListenUnderlying : Akka.Remote.Transport.TransportOperation
707+
{
708+
public ListenUnderlying(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> upstreamListener) { }
709+
public Akka.Actor.Address ListenAddress { get; }
710+
public System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> UpstreamListener { get; }
711+
}
712+
public sealed class ListenerRegistered : Akka.Remote.Transport.TransportOperation
713+
{
714+
public ListenerRegistered(Akka.Remote.Transport.IAssociationEventListener listener) { }
715+
public Akka.Remote.Transport.IAssociationEventListener Listener { get; }
716+
}
672717
public class SchemeAugmenter
673718
{
674719
public readonly string AddedSchemeIdentifier;
@@ -788,6 +833,11 @@ namespace Akka.Remote.Transport
788833
public virtual System.Threading.Tasks.Task<bool> ManagementCommand(object message) { }
789834
public abstract System.Threading.Tasks.Task<bool> Shutdown();
790835
}
836+
public abstract class TransportOperation : Akka.Actor.INoSerializationVerificationNeeded
837+
{
838+
public static readonly System.TimeSpan AskTimeout;
839+
protected TransportOperation() { }
840+
}
791841
public sealed class UnderlyingTransportError : Akka.Actor.INoSerializationVerificationNeeded, Akka.Remote.Transport.IHandleEvent
792842
{
793843
public UnderlyingTransportError(System.Exception cause, string message) { }

‎src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveRemote.Net.verified.txt

+50
Original file line numberDiff line numberDiff line change
@@ -479,6 +479,18 @@ namespace Akka.Remote.Transport
479479
public override System.Threading.Tasks.Task<System.ValueTuple<Akka.Actor.Address, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.IAssociationEventListener>>> Listen() { }
480480
public override System.Threading.Tasks.Task<bool> Shutdown() { }
481481
}
482+
public abstract class AbstractTransportAdapterHandle : Akka.Remote.Transport.AssociationHandle
483+
{
484+
protected AbstractTransportAdapterHandle(Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
485+
protected AbstractTransportAdapterHandle(Akka.Actor.Address originalLocalAddress, Akka.Actor.Address originalRemoteAddress, Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
486+
public Akka.Actor.Address OriginalLocalAddress { get; }
487+
public Akka.Actor.Address OriginalRemoteAddress { get; }
488+
protected Akka.Remote.Transport.SchemeAugmenter SchemeAugmenter { get; }
489+
public Akka.Remote.Transport.AssociationHandle WrappedHandle { get; }
490+
protected bool Equals(Akka.Remote.Transport.AbstractTransportAdapterHandle other) { }
491+
public override bool Equals(object obj) { }
492+
public override int GetHashCode() { }
493+
}
482494
public abstract class Activity
483495
{
484496
protected Activity() { }
@@ -506,6 +518,17 @@ namespace Akka.Remote.Transport
506518
protected override System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> InterceptListen(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> listenerTask) { }
507519
public override System.Threading.Tasks.Task<bool> Shutdown() { }
508520
}
521+
public abstract class ActorTransportAdapterManager : Akka.Actor.UntypedActor
522+
{
523+
protected Akka.Remote.Transport.IAssociationEventListener AssociationListener;
524+
protected System.Collections.Generic.Queue<object> DelayedEvents;
525+
protected Akka.Actor.Address LocalAddress;
526+
protected long UniqueId;
527+
protected ActorTransportAdapterManager() { }
528+
protected long NextId() { }
529+
protected override void OnReceive(object message) { }
530+
protected abstract void Ready(object message);
531+
}
509532
public class AkkaProtocolException : Akka.Actor.AkkaException
510533
{
511534
public AkkaProtocolException(string message, System.Exception cause = null) { }
@@ -517,6 +540,12 @@ namespace Akka.Remote.Transport
517540
public Akka.Actor.Address LocalAddress { get; }
518541
public Akka.Actor.Address RemoteAddress { get; }
519542
}
543+
public sealed class AssociateUnderlying : Akka.Remote.Transport.TransportOperation
544+
{
545+
public AssociateUnderlying(Akka.Actor.Address remoteAddress, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> statusPromise) { }
546+
public Akka.Actor.Address RemoteAddress { get; }
547+
public System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> StatusPromise { get; }
548+
}
520549
public abstract class AssociationHandle
521550
{
522551
protected AssociationHandle(Akka.Actor.Address localAddress, Akka.Actor.Address remoteAddress) { }
@@ -568,6 +597,11 @@ namespace Akka.Remote.Transport
568597
Shutdown = 1,
569598
Quarantined = 2,
570599
}
600+
public sealed class DisassociateUnderlying : Akka.Remote.Transport.TransportOperation, Akka.Event.IDeadLetterSuppression
601+
{
602+
public DisassociateUnderlying(Akka.Remote.Transport.DisassociateInfo info = 0) { }
603+
public Akka.Remote.Transport.DisassociateInfo Info { get; }
604+
}
571605
public sealed class Disassociated : Akka.Actor.INoSerializationVerificationNeeded, Akka.Event.IDeadLetterSuppression, Akka.Remote.Transport.IHandleEvent
572606
{
573607
public Disassociated(Akka.Remote.Transport.DisassociateInfo info) { }
@@ -669,6 +703,17 @@ namespace Akka.Remote.Transport
669703
public ListenAttempt(Akka.Actor.Address boundAddress) { }
670704
public Akka.Actor.Address BoundAddress { get; }
671705
}
706+
public sealed class ListenUnderlying : Akka.Remote.Transport.TransportOperation
707+
{
708+
public ListenUnderlying(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> upstreamListener) { }
709+
public Akka.Actor.Address ListenAddress { get; }
710+
public System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> UpstreamListener { get; }
711+
}
712+
public sealed class ListenerRegistered : Akka.Remote.Transport.TransportOperation
713+
{
714+
public ListenerRegistered(Akka.Remote.Transport.IAssociationEventListener listener) { }
715+
public Akka.Remote.Transport.IAssociationEventListener Listener { get; }
716+
}
672717
public class SchemeAugmenter
673718
{
674719
public readonly string AddedSchemeIdentifier;
@@ -788,6 +833,11 @@ namespace Akka.Remote.Transport
788833
public virtual System.Threading.Tasks.Task<bool> ManagementCommand(object message) { }
789834
public abstract System.Threading.Tasks.Task<bool> Shutdown();
790835
}
836+
public abstract class TransportOperation : Akka.Actor.INoSerializationVerificationNeeded
837+
{
838+
public static readonly System.TimeSpan AskTimeout;
839+
protected TransportOperation() { }
840+
}
791841
public sealed class UnderlyingTransportError : Akka.Actor.INoSerializationVerificationNeeded, Akka.Remote.Transport.IHandleEvent
792842
{
793843
public UnderlyingTransportError(System.Exception cause, string message) { }

‎src/core/Akka.Remote/Transport/TransportAdapters.cs

+7-7
Original file line numberDiff line numberDiff line change
@@ -303,7 +303,7 @@ public override Task<bool> Shutdown()
303303
/// <summary>
304304
/// TBD
305305
/// </summary>
306-
internal abstract class AbstractTransportAdapterHandle : AssociationHandle
306+
public abstract class AbstractTransportAdapterHandle : AssociationHandle
307307
{
308308
/// <summary>
309309
/// TBD
@@ -385,7 +385,7 @@ public override int GetHashCode()
385385
/// <summary>
386386
/// Marker interface for all transport operations
387387
/// </summary>
388-
internal abstract class TransportOperation : INoSerializationVerificationNeeded
388+
public abstract class TransportOperation : INoSerializationVerificationNeeded
389389
{
390390
/// <summary>
391391
/// TBD
@@ -396,7 +396,7 @@ internal abstract class TransportOperation : INoSerializationVerificationNeeded
396396
/// <summary>
397397
/// TBD
398398
/// </summary>
399-
internal sealed class ListenerRegistered : TransportOperation
399+
public sealed class ListenerRegistered : TransportOperation
400400
{
401401
/// <summary>
402402
/// TBD
@@ -416,7 +416,7 @@ public ListenerRegistered(IAssociationEventListener listener)
416416
/// <summary>
417417
/// TBD
418418
/// </summary>
419-
internal sealed class AssociateUnderlying : TransportOperation
419+
public sealed class AssociateUnderlying : TransportOperation
420420
{
421421
/// <summary>
422422
/// TBD
@@ -443,7 +443,7 @@ public AssociateUnderlying(Address remoteAddress, TaskCompletionSource<Associati
443443
/// <summary>
444444
/// TBD
445445
/// </summary>
446-
internal sealed class ListenUnderlying : TransportOperation
446+
public sealed class ListenUnderlying : TransportOperation
447447
{
448448
/// <summary>
449449
/// TBD
@@ -470,7 +470,7 @@ public ListenUnderlying(Address listenAddress, Task<IAssociationEventListener> u
470470
/// <summary>
471471
/// TBD
472472
/// </summary>
473-
internal sealed class DisassociateUnderlying : TransportOperation, IDeadLetterSuppression
473+
public sealed class DisassociateUnderlying : TransportOperation, IDeadLetterSuppression
474474
{
475475
/// <summary>
476476
/// TBD
@@ -556,7 +556,7 @@ public override Task<bool> Shutdown()
556556
/// <summary>
557557
/// TBD
558558
/// </summary>
559-
internal abstract class ActorTransportAdapterManager : UntypedActor
559+
public abstract class ActorTransportAdapterManager : UntypedActor
560560
{
561561
/// <summary>
562562
/// Lightweight Stash implementation

0 commit comments

Comments
 (0)