Skip to content

Commit

Permalink
discard un used parameters
Browse files Browse the repository at this point in the history
  • Loading branch information
SimonCropp committed Jun 7, 2021
1 parent 2c8b90b commit d0cf73b
Show file tree
Hide file tree
Showing 12 changed files with 107 additions and 112 deletions.
124 changes: 62 additions & 62 deletions sandbox/MessagePipe.AnalyzerTestApp/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -10,34 +10,34 @@ namespace MessagePipe.AnalyzerTestApp

class Program
{
static void Main(string[] args)
static void Main()
{
Observable.Range(1, 10).Subscribe(x => Console.WriteLine("OK Rx"));
Observable.Range(1, 10).Subscribe(_ => Console.WriteLine("OK Rx"));
}

static IDisposable Ret(ISubscriber<int> subscriber)
{
return subscriber.Subscribe(x => Console.WriteLine("OK RETURN"));
return subscriber.Subscribe(_ => Console.WriteLine("OK RETURN"));
}

static IDisposable Ret(ISubscriber<int, int> subscriber)
{
return subscriber.Subscribe(0, x => Console.WriteLine("OK RETURN"));
return subscriber.Subscribe(0, _ => Console.WriteLine("OK RETURN"));
}

static IDisposable Ret(IAsyncSubscriber<int> subscriber)
{
return subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK RETURN"));
return subscriber.Subscribe(async (_, _) => Console.WriteLine("OK RETURN"));
}

static IDisposable Ret(IAsyncSubscriber<int, int> subscriber)
{
return subscriber.Subscribe(0, async (x, ct) => Console.WriteLine("OK RETURN"));
return subscriber.Subscribe(0, async (_, _) => Console.WriteLine("OK RETURN"));
}

static IDisposable Ret(IBufferedSubscriber<int> subscriber)
{
return subscriber.Subscribe(x => Console.WriteLine("OK RETURN"));
return subscriber.Subscribe(_ => Console.WriteLine("OK RETURN"));
}

class MyClass
Expand All @@ -50,157 +50,157 @@ public MyClass(IDisposable d)

static void Subscriber(ISubscriber<int> subscriber)
{
subscriber.Subscribe(x => Console.WriteLine("NG NOT HANDLED"));
subscriber.Subscribe(_ => Console.WriteLine("NG NOT HANDLED"));

var d = subscriber.Subscribe(x => Console.WriteLine("OK ASSIGN"));
var d = subscriber.Subscribe(_ => Console.WriteLine("OK ASSIGN"));

IDisposable d1;
d1 = subscriber.Subscribe(x => Console.WriteLine("OK ASSIGN2"));
d1 = subscriber.Subscribe(_ => Console.WriteLine("OK ASSIGN2"));

_ = subscriber.Subscribe(x => Console.WriteLine("OK ASSIGN3"));
_ = subscriber.Subscribe(_ => Console.WriteLine("OK ASSIGN3"));

DisposableBag.Create(subscriber.Subscribe(x => Console.WriteLine("OK METHOD ARG1")));
DisposableBag.Create(subscriber.Subscribe(_ => Console.WriteLine("OK METHOD ARG1")));

var bag = DisposableBag.CreateBuilder();
subscriber.Subscribe(x => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);
subscriber.Subscribe(_ => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);

Enumerable.Range(1, 10).Select(x => subscriber.Subscribe(y => Console.WriteLine("OK IN LAMBDA")));
Enumerable.Range(1, 10).Select(_ => subscriber.Subscribe(_ => Console.WriteLine("OK IN LAMBDA")));

new MyClass(subscriber.Subscribe(x => Console.WriteLine("OK CTOR")));
new MyClass(subscriber.Subscribe(_ => Console.WriteLine("OK CTOR")));

using (subscriber.Subscribe(x => Console.WriteLine("OK USING")))
using (subscriber.Subscribe(_ => Console.WriteLine("OK USING")))
{
}

using (subscriber.Subscribe(x => Console.WriteLine("OK USING2")))
using (subscriber.Subscribe(_ => Console.WriteLine("OK USING2")))
{
}

using var u = subscriber.Subscribe(x => Console.WriteLine("OK USING 3"));
using var u = subscriber.Subscribe(_ => Console.WriteLine("OK USING 3"));
}

static void Subscriber2(ISubscriber<string, int> subscriber)
{
subscriber.Subscribe("a", x => Console.WriteLine("NG NOT HANDLED"));
subscriber.Subscribe("a", _ => Console.WriteLine("NG NOT HANDLED"));

var d = subscriber.Subscribe("a", x => Console.WriteLine("OK ASSIGN"));
var d = subscriber.Subscribe("a", _ => Console.WriteLine("OK ASSIGN"));

IDisposable d1;
d1 = subscriber.Subscribe("a", x => Console.WriteLine("OK ASSIGN2"));
d1 = subscriber.Subscribe("a", _ => Console.WriteLine("OK ASSIGN2"));

_ = subscriber.Subscribe("a", x => Console.WriteLine("OK ASSIGN3"));
_ = subscriber.Subscribe("a", _ => Console.WriteLine("OK ASSIGN3"));

DisposableBag.Create(subscriber.Subscribe("a", x => Console.WriteLine("OK METHOD ARG1")));
DisposableBag.Create(subscriber.Subscribe("a", _ => Console.WriteLine("OK METHOD ARG1")));

var bag = DisposableBag.CreateBuilder();
subscriber.Subscribe("a", x => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);
subscriber.Subscribe("a", _ => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);

Enumerable.Range(1, 10).Select(x => subscriber.Subscribe("a", y => Console.WriteLine("OK IN LAMBDA")));
Enumerable.Range(1, 10).Select(_ => subscriber.Subscribe("a", _ => Console.WriteLine("OK IN LAMBDA")));

new MyClass(subscriber.Subscribe("a", x => Console.WriteLine("OK CTOR")));
new MyClass(subscriber.Subscribe("a", _ => Console.WriteLine("OK CTOR")));

using (subscriber.Subscribe("a", x => Console.WriteLine("OK USING")))
using (subscriber.Subscribe("a", _ => Console.WriteLine("OK USING")))
{
}

using (subscriber.Subscribe("a", x => Console.WriteLine("OK USING2")))
using (subscriber.Subscribe("a", _ => Console.WriteLine("OK USING2")))
{
}

using var u = subscriber.Subscribe("a", x => Console.WriteLine("OK USING 3"));
using var u = subscriber.Subscribe("a", _ => Console.WriteLine("OK USING 3"));
}

static void AsyncSubscriber(IAsyncSubscriber<int> subscriber)
{
subscriber.Subscribe(async (x, ct) => Console.WriteLine("NG NOT HANDLED"));
subscriber.Subscribe(async (_, _) => Console.WriteLine("NG NOT HANDLED"));

var d = subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK ASSIGN"));
var d = subscriber.Subscribe(async (_, _) => Console.WriteLine("OK ASSIGN"));

IDisposable d1;
d1 = subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK ASSIGN2"));
d1 = subscriber.Subscribe(async (_, _) => Console.WriteLine("OK ASSIGN2"));

_ = subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK ASSIGN3"));
_ = subscriber.Subscribe(async (_, _) => Console.WriteLine("OK ASSIGN3"));

DisposableBag.Create(subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK METHOD ARG1")));
DisposableBag.Create(subscriber.Subscribe(async (_, _) => Console.WriteLine("OK METHOD ARG1")));

var bag = DisposableBag.CreateBuilder();
subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);
subscriber.Subscribe(async (_, _) => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);

Enumerable.Range(1, 10).Select(x => subscriber.Subscribe(async (y, ct) => Console.WriteLine("OK IN LAMBDA")));
Enumerable.Range(1, 10).Select(_ => subscriber.Subscribe(async (_, _) => Console.WriteLine("OK IN LAMBDA")));

new MyClass(subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK CTOR")));
new MyClass(subscriber.Subscribe(async (_, _) => Console.WriteLine("OK CTOR")));

using (subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK USING")))
using (subscriber.Subscribe(async (_, _) => Console.WriteLine("OK USING")))
{
}

using (subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK USING2")))
using (subscriber.Subscribe(async (_, _) => Console.WriteLine("OK USING2")))
{
}

using var u = subscriber.Subscribe(async (x, ct) => Console.WriteLine("OK USING 3"));
using var u = subscriber.Subscribe(async (_, _) => Console.WriteLine("OK USING 3"));
}

static void AsyncSubscriber2(IAsyncSubscriber<string, int> subscriber)
{
subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("NG NOT HANDLED"));
subscriber.Subscribe("a", async (_, _) => Console.WriteLine("NG NOT HANDLED"));

var d = subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK ASSIGN"));
var d = subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK ASSIGN"));

IDisposable d1;
d1 = subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK ASSIGN2"));
d1 = subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK ASSIGN2"));

_ = subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK ASSIGN3"));
_ = subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK ASSIGN3"));

DisposableBag.Create(subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK METHOD ARG1")));
DisposableBag.Create(subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK METHOD ARG1")));

var bag = DisposableBag.CreateBuilder();
subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);
subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);

Enumerable.Range(1, 10).Select(async (x, ct) => subscriber.Subscribe("a", async (y, ct) => Console.WriteLine("OK IN LAMBDA")));
Enumerable.Range(1, 10).Select(async (_, _) => subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK IN LAMBDA")));

new MyClass(subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK CTOR")));
new MyClass(subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK CTOR")));

using (subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK USING")))
using (subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK USING")))
{
}

using (subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK USING2")))
using (subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK USING2")))
{
}

using var u = subscriber.Subscribe("a", async (x, ct) => Console.WriteLine("OK USING 3"));
using var u = subscriber.Subscribe("a", async (_, _) => Console.WriteLine("OK USING 3"));
}

static void BufferedSubscriber(IBufferedSubscriber<int> subscriber)
{
subscriber.Subscribe(x => Console.WriteLine("NG NOT HANDLED"));
subscriber.Subscribe(_ => Console.WriteLine("NG NOT HANDLED"));

var d = subscriber.Subscribe(x => Console.WriteLine("OK ASSIGN"));
var d = subscriber.Subscribe(_ => Console.WriteLine("OK ASSIGN"));

IDisposable d1;
d1 = subscriber.Subscribe(x => Console.WriteLine("OK ASSIGN2"));
d1 = subscriber.Subscribe(_ => Console.WriteLine("OK ASSIGN2"));

_ = subscriber.Subscribe(x => Console.WriteLine("OK ASSIGN3"));
_ = subscriber.Subscribe(_ => Console.WriteLine("OK ASSIGN3"));

DisposableBag.Create(subscriber.Subscribe(x => Console.WriteLine("OK METHOD ARG1")));
DisposableBag.Create(subscriber.Subscribe(_ => Console.WriteLine("OK METHOD ARG1")));

var bag = DisposableBag.CreateBuilder();
subscriber.Subscribe(x => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);
subscriber.Subscribe(_ => Console.WriteLine("OK METHOD CHAIN")).AddTo(bag);

Enumerable.Range(1, 10).Select(x => subscriber.Subscribe(y => Console.WriteLine("OK IN LAMBDA")));
Enumerable.Range(1, 10).Select(_ => subscriber.Subscribe(_ => Console.WriteLine("OK IN LAMBDA")));

new MyClass(subscriber.Subscribe(x => Console.WriteLine("OK CTOR")));
new MyClass(subscriber.Subscribe(_ => Console.WriteLine("OK CTOR")));

using (subscriber.Subscribe(x => Console.WriteLine("OK USING")))
using (subscriber.Subscribe(_ => Console.WriteLine("OK USING")))
{
}

using (subscriber.Subscribe(x => Console.WriteLine("OK USING2")))
using (subscriber.Subscribe(_ => Console.WriteLine("OK USING2")))
{
}

using var u = subscriber.Subscribe(x => Console.WriteLine("OK USING 3"));
using var u = subscriber.Subscribe(_ => Console.WriteLine("OK USING 3"));
}
}
}
6 changes: 3 additions & 3 deletions sandbox/MessagePipe.Sandbox.ConsoleApp/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ static async Task Main(string[] args)


var host = Host.CreateDefaultBuilder()
.ConfigureServices((ctx, x) =>
.ConfigureServices((_, x) =>
{

x.AddMessagePipe();
Expand All @@ -76,7 +76,7 @@ static async Task Main(string[] args)
args = new[] { "moremore" };

await Host.CreateDefaultBuilder()
.ConfigureServices((ctx, x) =>
.ConfigureServices((_, x) =>
{


Expand Down Expand Up @@ -369,7 +369,7 @@ public void CheckScope()
scope.Dispose();

p.Publish(129);
s.Subscribe(x => Console.WriteLine("s2???"));
s.Subscribe(_ => Console.WriteLine("s2???"));

p2.Publish(1999);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ internal static string GetGroupKey(StackTrace stackTrace)
[Preserve]
public sealed class MessagePipeDiagnosticsInfo
{
static readonly ILookup<string, StackTraceInfo> EmptyLookup = Array.Empty<StackTraceInfo>().ToLookup(x => "", x => x);
static readonly ILookup<string, StackTraceInfo> EmptyLookup = Array.Empty<StackTraceInfo>().ToLookup(_ => "", x => x);

int subscribeCount;
bool dirty;
Expand Down
2 changes: 1 addition & 1 deletion src/MessagePipe/MessagePipeDiagnosticsInfo.cs
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ internal static string GetGroupKey(StackTrace stackTrace)
[Preserve]
public sealed class MessagePipeDiagnosticsInfo
{
static readonly ILookup<string, StackTraceInfo> EmptyLookup = Array.Empty<StackTraceInfo>().ToLookup(x => "", x => x);
static readonly ILookup<string, StackTraceInfo> EmptyLookup = Array.Empty<StackTraceInfo>().ToLookup(_ => "", x => x);

int subscribeCount;
bool dirty;
Expand Down
16 changes: 8 additions & 8 deletions tests/MessagePipe.Benchmark/BenchmarkDotNetRun.cs
Original file line number Diff line number Diff line change
Expand Up @@ -78,14 +78,14 @@ public BenchmarkDotNetRun()

}

signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });

}

Expand Down
5 changes: 1 addition & 4 deletions tests/MessagePipe.Benchmark/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -2,16 +2,13 @@
using BenchmarkDotNet.Diagnosers;
using BenchmarkDotNet.Environments;
using BenchmarkDotNet.Jobs;
using BenchmarkDotNet.Running;
using System;
using System.Reflection;
using System.Threading.Tasks;

namespace MessagePipe.Benchmark
{
class Program
{
static async Task Main(string[] args)
static async Task Main()
{
await new PublishOps().MeasureAllAsync();

Expand Down
18 changes: 9 additions & 9 deletions tests/MessagePipe.Benchmark/PublishOps.cs
Original file line number Diff line number Diff line change
Expand Up @@ -169,20 +169,20 @@ public unsafe PublishOps()
actionDelegate[i] = new PlainAction().DelegateAction;
interfaceArray[i] = new PlainAction();

asyncS.Subscribe((_, c) => default(ValueTask));
asyncS.Subscribe((_, _) => default(ValueTask));

toolkitStrong.Register<Message>(new object(), lambdaRef2.Delegate);
toolkitWeak.Register<Message>(new object(), lambdaRef2.Delegate);
}

signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(m => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });
signalBus.Subscribe<Message>(_ => { });

}

Expand Down
Loading

0 comments on commit d0cf73b

Please sign in to comment.