From 505c95c827ee2201ee5d74f1ac4d447509f3ba35 Mon Sep 17 00:00:00 2001 From: Sean Gilliam Date: Fri, 27 Jan 2017 16:20:26 -0600 Subject: [PATCH] [api-docs] Various fixes This PR contains various fixes including filling in TBD placeholders, fixed numerous copyright headers and converted a repetitive class to a T4 template. --- .../PersistentShardCoordinator.Messages.cs | 2 - .../Properties/AssemblyInfo.cs | 9 +- .../Properties/AssemblyInfo.cs | 9 +- .../Properties/AssemblyInfo.cs | 9 +- .../Serialization/ReplicatedDataSerializer.cs | 9 +- .../ReplicatorMessageSerializer.cs | 9 +- .../DeliveryBuffer.cs | 2 +- .../BatchingSqliteAllPersistenceIdSpec.cs | 9 +- ...BatchingSqliteEventsByPersistenceIdSpec.cs | 9 +- .../Batching/BatchingSqliteEventsByTagSpec.cs | 9 +- .../Batching/BatchingSqliteJournalSpec.cs | 9 +- .../Query/SqliteAllPersistenceIdsSpec.cs | 2 +- .../Properties/AssemblyInfo.cs | 9 +- .../Properties/AssemblyInfo.cs | 9 +- .../CoreAPISpec.ApproveCore.approved.txt | 2 +- .../MultiNodeClusterSpec.cs | 2 +- src/core/Akka.Persistence.Query/Interfaces.cs | 2 +- .../PersistentActorRecoveryTimeoutSpec.cs | 2 +- .../Eventsourced.Lifecycle.cs | 2 - .../RemoteReDeploymentSpec.cs | 2 +- src/core/Akka.Remote/Endpoint.cs | 1 + .../Akka.Remote/Transport/AkkaPduCodec.cs | 3 - .../FusedGraphsBenchmark.cs | 9 +- .../JsonFramingBenchmark.cs | 9 +- .../AkkaSubscriberVerification.cs | 2 +- .../VirtualPublisherTest.cs | 2 +- .../Dsl/FlowSelectAsyncUnorderedSpec.cs | 2 +- src/core/Akka.Streams/Dsl/Hub.cs | 9 +- .../Implementation/UntypedVirtualPublisher.cs | 2 +- src/core/Akka.Streams/Stage/AbstractStage.cs | 11 +- src/core/Akka.TestKit/TestKitBase_ActorOf.cs | 2 +- src/core/Akka.TestKit/TestProbe.cs | 2 +- .../Scheduler/HashedWheelTimerScheduler.cs | 4 +- src/core/Akka/Akka.csproj | 14 +- .../Hocon/AkkaConfigurationSection.cs | 2 + .../Hocon/CDataConfigurationElement.cs | 6 +- .../Configuration/Hocon/HoconTokenizer.cs | 20 +-- src/core/Akka/IO/ByteBuffer.cs | 2 +- src/core/Akka/IO/Inet.cs | 2 - src/core/Akka/IO/Tcp.cs | 2 - src/core/Akka/Routing/Broadcast.cs | 19 ++- src/core/Akka/Routing/ConsistentHash.cs | 154 ++++++++---------- src/core/Akka/Routing/ConsistentHashRouter.cs | 24 ++- src/core/Akka/Routing/Random.cs | 12 +- src/core/Akka/Routing/RoundRobin.cs | 16 +- src/core/Akka/Routing/RouterConfig.cs | 14 +- .../Routing/ScatterGatherFirstCompleted.cs | 22 +-- src/core/Akka/Routing/SmallestMailbox.cs | 6 +- src/core/Akka/Routing/TailChopping.cs | 24 ++- src/core/Akka/Util/ByteString.cs | 2 - .../PartialHandlerArgumentsCapture.cs | 33 +--- .../PartialHandlerArgumentsCapture.tt | 102 ++++++++++++ src/core/Akka/Util/MonotonicClock.cs | 3 - 53 files changed, 413 insertions(+), 241 deletions(-) create mode 100644 src/core/Akka/Util/MatchHandler/PartialHandlerArgumentsCapture.tt diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.Messages.cs b/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.Messages.cs index a0f982e6be0..6c06119b52e 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.Messages.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.Messages.cs @@ -948,12 +948,10 @@ public class ShardHomeAllocated : IDomainEvent /// /// TBD /// - /// TBD public readonly ShardId Shard; /// /// TBD /// - /// TBD public readonly IActorRef Region; /// diff --git a/src/contrib/cluster/Akka.DistributedData.Tests.MultiNode/Properties/AssemblyInfo.cs b/src/contrib/cluster/Akka.DistributedData.Tests.MultiNode/Properties/AssemblyInfo.cs index 06bef7e4294..811d1a7b3ee 100644 --- a/src/contrib/cluster/Akka.DistributedData.Tests.MultiNode/Properties/AssemblyInfo.cs +++ b/src/contrib/cluster/Akka.DistributedData.Tests.MultiNode/Properties/AssemblyInfo.cs @@ -1,4 +1,11 @@ -using System.Reflection; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System.Reflection; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; diff --git a/src/contrib/cluster/Akka.DistributedData.Tests/Properties/AssemblyInfo.cs b/src/contrib/cluster/Akka.DistributedData.Tests/Properties/AssemblyInfo.cs index 0a77c1342b3..ab0b48d108e 100644 --- a/src/contrib/cluster/Akka.DistributedData.Tests/Properties/AssemblyInfo.cs +++ b/src/contrib/cluster/Akka.DistributedData.Tests/Properties/AssemblyInfo.cs @@ -1,4 +1,11 @@ -using System.Reflection; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System.Reflection; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; diff --git a/src/contrib/cluster/Akka.DistributedData/Properties/AssemblyInfo.cs b/src/contrib/cluster/Akka.DistributedData/Properties/AssemblyInfo.cs index 2ceeab0482b..f32893d0d19 100644 --- a/src/contrib/cluster/Akka.DistributedData/Properties/AssemblyInfo.cs +++ b/src/contrib/cluster/Akka.DistributedData/Properties/AssemblyInfo.cs @@ -1,4 +1,11 @@ -using System.Reflection; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System.Reflection; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; diff --git a/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatedDataSerializer.cs b/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatedDataSerializer.cs index d247e865d95..8fadbcfbd32 100644 --- a/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatedDataSerializer.cs +++ b/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatedDataSerializer.cs @@ -1,4 +1,11 @@ -using System; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System; using System.IO; using Akka.Actor; using Akka.Util; diff --git a/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatorMessageSerializer.cs b/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatorMessageSerializer.cs index 033f669cc67..74802718ca6 100644 --- a/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatorMessageSerializer.cs +++ b/src/contrib/cluster/Akka.DistributedData/Serialization/ReplicatorMessageSerializer.cs @@ -1,4 +1,11 @@ -using System; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System; using System.Collections.Generic; using System.IO; using Akka.Actor; diff --git a/src/contrib/persistence/Akka.Persistence.Query.Sql/DeliveryBuffer.cs b/src/contrib/persistence/Akka.Persistence.Query.Sql/DeliveryBuffer.cs index 764b088a174..e7ed28b6d9a 100644 --- a/src/contrib/persistence/Akka.Persistence.Query.Sql/DeliveryBuffer.cs +++ b/src/contrib/persistence/Akka.Persistence.Query.Sql/DeliveryBuffer.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2009-2016 Typesafe Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteAllPersistenceIdSpec.cs b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteAllPersistenceIdSpec.cs index 1b6980af780..6b53e9715ad 100644 --- a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteAllPersistenceIdSpec.cs +++ b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteAllPersistenceIdSpec.cs @@ -1,4 +1,11 @@ -using Akka.Configuration; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Typesafe Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using Akka.Configuration; using Akka.Persistence.Query.Sql; using Akka.Persistence.Sql.TestKit; using Akka.Util.Internal; diff --git a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByPersistenceIdSpec.cs b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByPersistenceIdSpec.cs index b889d057b92..a8614fbb691 100644 --- a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByPersistenceIdSpec.cs +++ b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByPersistenceIdSpec.cs @@ -1,4 +1,11 @@ -using Akka.Configuration; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Typesafe Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using Akka.Configuration; using Akka.Persistence.Query.Sql; using Akka.Persistence.Sql.TestKit; using Akka.Util.Internal; diff --git a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByTagSpec.cs b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByTagSpec.cs index 135696a6ea7..35dceeef32f 100644 --- a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByTagSpec.cs +++ b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteEventsByTagSpec.cs @@ -1,4 +1,11 @@ -using Akka.Configuration; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Typesafe Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using Akka.Configuration; using Akka.Persistence.Query.Sql; using Akka.Persistence.Sql.TestKit; using Akka.Util.Internal; diff --git a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteJournalSpec.cs b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteJournalSpec.cs index dd8d055089d..c7f1a37d2a1 100644 --- a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteJournalSpec.cs +++ b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Batching/BatchingSqliteJournalSpec.cs @@ -1,4 +1,11 @@ -using Akka.Configuration; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Typesafe Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using Akka.Configuration; using Akka.Persistence.TestKit.Journal; using Akka.Util.Internal; using Xunit.Abstractions; diff --git a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Query/SqliteAllPersistenceIdsSpec.cs b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Query/SqliteAllPersistenceIdsSpec.cs index b3c1da9a33f..2358661e887 100644 --- a/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Query/SqliteAllPersistenceIdsSpec.cs +++ b/src/contrib/persistence/Akka.Persistence.Sqlite.Tests/Query/SqliteAllPersistenceIdsSpec.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2009-2016 Typesafe Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/contrib/serializers/Akka.Serialization.Hyperion.Tests/Properties/AssemblyInfo.cs b/src/contrib/serializers/Akka.Serialization.Hyperion.Tests/Properties/AssemblyInfo.cs index f9a414e38a9..6765942f8b5 100644 --- a/src/contrib/serializers/Akka.Serialization.Hyperion.Tests/Properties/AssemblyInfo.cs +++ b/src/contrib/serializers/Akka.Serialization.Hyperion.Tests/Properties/AssemblyInfo.cs @@ -1,4 +1,11 @@ -using System.Reflection; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System.Reflection; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; diff --git a/src/contrib/serializers/Akka.Serialization.Hyperion/Properties/AssemblyInfo.cs b/src/contrib/serializers/Akka.Serialization.Hyperion/Properties/AssemblyInfo.cs index 688f1c524de..e2d124d61be 100644 --- a/src/contrib/serializers/Akka.Serialization.Hyperion/Properties/AssemblyInfo.cs +++ b/src/contrib/serializers/Akka.Serialization.Hyperion/Properties/AssemblyInfo.cs @@ -1,4 +1,11 @@ -using System.Reflection; +//----------------------------------------------------------------------- +// +// Copyright (C) 2009-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System.Reflection; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; diff --git a/src/core/Akka.API.Tests/CoreAPISpec.ApproveCore.approved.txt b/src/core/Akka.API.Tests/CoreAPISpec.ApproveCore.approved.txt index 1c2364f83e4..707925068dc 100644 --- a/src/core/Akka.API.Tests/CoreAPISpec.ApproveCore.approved.txt +++ b/src/core/Akka.API.Tests/CoreAPISpec.ApproveCore.approved.txt @@ -4639,7 +4639,7 @@ namespace Akka.Tools.MatchHandler public sealed class PartialHandlerArgumentsCapture : Akka.Tools.MatchHandler.IPartialHandlerArgumentsCapture { public PartialHandlerArgumentsCapture() { } - public bool Handle(T message) { } + public bool Handle(T value) { } public void Initialize(System.Delegate handler, System.Collections.Generic.IReadOnlyList arguments) { } } public sealed class PartialHandlerArgumentsCapture : Akka.Tools.MatchHandler.IPartialHandlerArgumentsCapture diff --git a/src/core/Akka.Cluster.TestKit/MultiNodeClusterSpec.cs b/src/core/Akka.Cluster.TestKit/MultiNodeClusterSpec.cs index c823157c86c..2a16cc1b89d 100644 --- a/src/core/Akka.Cluster.TestKit/MultiNodeClusterSpec.cs +++ b/src/core/Akka.Cluster.TestKit/MultiNodeClusterSpec.cs @@ -249,7 +249,7 @@ public void StartClusterNode() } /// - /// Initialize the cluster of the specified member nodes () + /// Initialize the cluster of the specified member nodes () /// and wait until all joined and . /// /// First node will be started first and others will join the first. diff --git a/src/core/Akka.Persistence.Query/Interfaces.cs b/src/core/Akka.Persistence.Query/Interfaces.cs index d51749ff167..10962cb8085 100644 --- a/src/core/Akka.Persistence.Query/Interfaces.cs +++ b/src/core/Akka.Persistence.Query/Interfaces.cs @@ -83,7 +83,7 @@ public interface IEventsByPersistenceIdQuery : IReadJournal /// Query events for a specific identified by . /// /// You can retrieve a subset of all events by specifying and - /// or use and respectively to retrieve all events. + /// or use 0L and respectively to retrieve all events. /// /// The returned event stream should be ordered by sequence number. /// diff --git a/src/core/Akka.Persistence.Tests/PersistentActorRecoveryTimeoutSpec.cs b/src/core/Akka.Persistence.Tests/PersistentActorRecoveryTimeoutSpec.cs index 281be5fa120..926a2a967f7 100644 --- a/src/core/Akka.Persistence.Tests/PersistentActorRecoveryTimeoutSpec.cs +++ b/src/core/Akka.Persistence.Tests/PersistentActorRecoveryTimeoutSpec.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2009-2016 Lightbend Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/core/Akka.Persistence/Eventsourced.Lifecycle.cs b/src/core/Akka.Persistence/Eventsourced.Lifecycle.cs index 486e7c73556..1650f67de71 100644 --- a/src/core/Akka.Persistence/Eventsourced.Lifecycle.cs +++ b/src/core/Akka.Persistence/Eventsourced.Lifecycle.cs @@ -18,8 +18,6 @@ public partial class Eventsourced /// /// TBD /// - /// TBD - /// TBD public static readonly Func UnstashFilterPredicate = envelope => !(envelope.Message is WriteMessageSuccess || envelope.Message is ReplayedMessage); diff --git a/src/core/Akka.Remote.Tests.MultiNode/RemoteReDeploymentSpec.cs b/src/core/Akka.Remote.Tests.MultiNode/RemoteReDeploymentSpec.cs index 3399669c608..abeb035a476 100644 --- a/src/core/Akka.Remote.Tests.MultiNode/RemoteReDeploymentSpec.cs +++ b/src/core/Akka.Remote.Tests.MultiNode/RemoteReDeploymentSpec.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2009-2016 Lightbend Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/core/Akka.Remote/Endpoint.cs b/src/core/Akka.Remote/Endpoint.cs index 457efd7d2a0..2dcc1737747 100644 --- a/src/core/Akka.Remote/Endpoint.cs +++ b/src/core/Akka.Remote/Endpoint.cs @@ -211,6 +211,7 @@ internal sealed class ShutDownAssociation : EndpointException, IAssociationProbl /// /// TBD /// + /// TBD /// TBD /// TBD /// TBD diff --git a/src/core/Akka.Remote/Transport/AkkaPduCodec.cs b/src/core/Akka.Remote/Transport/AkkaPduCodec.cs index ceb90e68ab3..e74bfcc1c62 100644 --- a/src/core/Akka.Remote/Transport/AkkaPduCodec.cs +++ b/src/core/Akka.Remote/Transport/AkkaPduCodec.cs @@ -136,9 +136,6 @@ public Message(IInternalActorRef recipient, Address recipientAddress, Serialized /// /// TBD /// - /// TBD - /// TBD - /// TBD public IInternalActorRef Recipient { get; private set; } /// diff --git a/src/core/Akka.Streams.Tests.Performance/FusedGraphsBenchmark.cs b/src/core/Akka.Streams.Tests.Performance/FusedGraphsBenchmark.cs index 944680d258c..fbe90464864 100644 --- a/src/core/Akka.Streams.Tests.Performance/FusedGraphsBenchmark.cs +++ b/src/core/Akka.Streams.Tests.Performance/FusedGraphsBenchmark.cs @@ -1,4 +1,11 @@ -using System; +//----------------------------------------------------------------------- +// +// Copyright (C) 2015-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System; using System.Linq; using Akka.Actor; using Akka.Streams.Dsl; diff --git a/src/core/Akka.Streams.Tests.Performance/JsonFramingBenchmark.cs b/src/core/Akka.Streams.Tests.Performance/JsonFramingBenchmark.cs index ef34590c0d7..625c62a516f 100644 --- a/src/core/Akka.Streams.Tests.Performance/JsonFramingBenchmark.cs +++ b/src/core/Akka.Streams.Tests.Performance/JsonFramingBenchmark.cs @@ -1,4 +1,11 @@ -using Akka.IO; +//----------------------------------------------------------------------- +// +// Copyright (C) 2015-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using Akka.IO; using Akka.Streams.Implementation; using NBench; diff --git a/src/core/Akka.Streams.Tests.TCK/AkkaSubscriberVerification.cs b/src/core/Akka.Streams.Tests.TCK/AkkaSubscriberVerification.cs index 63dcaeea9cb..8ae904f9553 100644 --- a/src/core/Akka.Streams.Tests.TCK/AkkaSubscriberVerification.cs +++ b/src/core/Akka.Streams.Tests.TCK/AkkaSubscriberVerification.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2015-2016 Lightbend Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/core/Akka.Streams.Tests.TCK/VirtualPublisherTest.cs b/src/core/Akka.Streams.Tests.TCK/VirtualPublisherTest.cs index 01b2ad7a333..64f7cdf6596 100644 --- a/src/core/Akka.Streams.Tests.TCK/VirtualPublisherTest.cs +++ b/src/core/Akka.Streams.Tests.TCK/VirtualPublisherTest.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2015-2016 Lightbend Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/core/Akka.Streams.Tests/Dsl/FlowSelectAsyncUnorderedSpec.cs b/src/core/Akka.Streams.Tests/Dsl/FlowSelectAsyncUnorderedSpec.cs index d16ddf22df1..c8c78907341 100644 --- a/src/core/Akka.Streams.Tests/Dsl/FlowSelectAsyncUnorderedSpec.cs +++ b/src/core/Akka.Streams.Tests/Dsl/FlowSelectAsyncUnorderedSpec.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2015-2016 Lightbend Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/core/Akka.Streams/Dsl/Hub.cs b/src/core/Akka.Streams/Dsl/Hub.cs index 637e9165aff..8940182ad37 100644 --- a/src/core/Akka.Streams/Dsl/Hub.cs +++ b/src/core/Akka.Streams/Dsl/Hub.cs @@ -1,4 +1,11 @@ -using System; +//----------------------------------------------------------------------- +// +// Copyright (C) 2015-2016 Lightbend Inc. +// Copyright (C) 2013-2016 Akka.NET project +// +//----------------------------------------------------------------------- + +using System; using System.Collections.Concurrent; using System.Collections.Generic; using System.Collections.Immutable; diff --git a/src/core/Akka.Streams/Implementation/UntypedVirtualPublisher.cs b/src/core/Akka.Streams/Implementation/UntypedVirtualPublisher.cs index 1ee12411221..014f14a068c 100644 --- a/src/core/Akka.Streams/Implementation/UntypedVirtualPublisher.cs +++ b/src/core/Akka.Streams/Implementation/UntypedVirtualPublisher.cs @@ -1,5 +1,5 @@ //----------------------------------------------------------------------- -// +// // Copyright (C) 2015-2016 Lightbend Inc. // Copyright (C) 2013-2016 Akka.NET project // diff --git a/src/core/Akka.Streams/Stage/AbstractStage.cs b/src/core/Akka.Streams/Stage/AbstractStage.cs index b3960926a98..06121420298 100644 --- a/src/core/Akka.Streams/Stage/AbstractStage.cs +++ b/src/core/Akka.Streams/Stage/AbstractStage.cs @@ -199,18 +199,14 @@ public FreeDirective PushAndPull(TOut element) /// /// TBD /// - /// TBD - /// TBD - /// TBD + /// TBD /// TBD public IUpstreamDirective HoldUpstreamAndPush(object element) => HoldUpstreamAndPush((TOut) element); /// /// TBD /// - /// TBD - /// TBD - /// TBD + /// TBD /// TBD public IUpstreamDirective HoldUpstreamAndPush(TOut element) { @@ -221,9 +217,6 @@ public IUpstreamDirective HoldUpstreamAndPush(TOut element) /// /// TBD /// - /// TBD - /// TBD - /// TBD /// TBD public IDownstreamDirective HoldDownstreamAndPull() { diff --git a/src/core/Akka.TestKit/TestKitBase_ActorOf.cs b/src/core/Akka.TestKit/TestKitBase_ActorOf.cs index 8d9dc92ae6e..86ec8853b2c 100644 --- a/src/core/Akka.TestKit/TestKitBase_ActorOf.cs +++ b/src/core/Akka.TestKit/TestKitBase_ActorOf.cs @@ -153,7 +153,7 @@ public ActorSelection ActorSelection(string actorPath) /// /// Creates an /// - /// The base actor that anchros the . + /// The base actor that anchros the . /// The path of the actor(s) we want to select. /// An ActorSelection public ActorSelection ActorSelection(IActorRef anchorRef, string actorPath) diff --git a/src/core/Akka.TestKit/TestProbe.cs b/src/core/Akka.TestKit/TestProbe.cs index b938bdf2898..0eff06cea39 100644 --- a/src/core/Akka.TestKit/TestProbe.cs +++ b/src/core/Akka.TestKit/TestProbe.cs @@ -175,7 +175,7 @@ public void SendSystemMessage(ISystemMessage message) /// Compares the underlying actor ref to the object. /// /// The object to be compared to; ideally an . - /// An integer indicating if the actor sorts higher, lower, or equal to . + /// An integer indicating if the actor sorts higher, lower, or equal to . public int CompareTo(object obj) { return TestActor.CompareTo(obj); diff --git a/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs b/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs index 5da97cfac91..d6e69f81573 100644 --- a/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs +++ b/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs @@ -99,7 +99,7 @@ private static Bucket[] CreateWheel(int ticksPerWheel, ILoggingAdapter log) /// Normalize a wheel size to the nearest power of 2. /// /// The original input per wheel. - /// normalized to the nearest power of 2. + /// normalized to the nearest power of 2. private static int NormalizeTicksPerWheel(int ticksPerWheel) { var normalizedTicksPerWheel = 1; @@ -576,7 +576,7 @@ public void ClearReschedule(HashSet registrations) private static readonly Action ExecuteRunnableWithState = r => ((IRunnable)r).Run(); /// - /// Execute all s that are due by or after . + /// Execute all s that are due by or after . /// /// The execution time. public void Execute(long deadline) diff --git a/src/core/Akka/Akka.csproj b/src/core/Akka/Akka.csproj index fdb0341355d..e4e7d515a06 100644 --- a/src/core/Akka/Akka.csproj +++ b/src/core/Akka/Akka.csproj @@ -285,6 +285,11 @@ + + True + True + PartialHandlerArgumentsCapture.tt + @@ -349,7 +354,6 @@ - @@ -381,8 +385,14 @@ PreserveNewest + + TextTemplatingFileGenerator + PartialHandlerArgumentsCapture.cs + + + + -