MStart
diff --git a/‎src/main/java/io/reactivesocket/exceptions/Exceptions.java
Lines changed: 1 addition & 1 deletion b/‎src/main/java/io/reactivesocket/exceptions/Exceptions.java
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/main/java/io/reactivesocket/internal/Requester.java
Lines changed: 2 additions & 2 deletions b/‎src/main/java/io/reactivesocket/internal/Requester.java
Lines changed: 2 additions & 2 deletions
diff --git a/‎src/main/java/io/reactivesocket/internal/Responder.java
Lines changed: 4 additions & 4 deletions b/‎src/main/java/io/reactivesocket/internal/Responder.java
Lines changed: 4 additions & 4 deletions
diff --git a/‎src/main/java/io/reactivesocket/internal/rx/CompositeDisposable.java
Lines changed: 1 addition & 1 deletion b/‎src/main/java/io/reactivesocket/internal/rx/CompositeDisposable.java
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/main/java/io/reactivesocket/lease/FairLeaseGovernor.java
Lines changed: 1 addition & 1 deletion b/‎src/main/java/io/reactivesocket/lease/FairLeaseGovernor.java
Lines changed: 1 addition & 1 deletion
@@ -31,7 +31,7 @@ public static Throwable from(Frame frame) {
             message = new String(byteBuffer.array(), UTF_8);
         }
 
-        Throwable ex = null;
+        Throwable ex;
         switch (errorCode) {
             case APPLICATION_ERROR:
                 ex = new ApplicationException(message);
 
@@ -947,7 +947,7 @@ public void onNext(Frame frame) {
             }
 
             public void onError(Throwable t) {
-                Collection<UnicastSubject<Frame>> subjects = null;
+                Collection<UnicastSubject<Frame>> subjects;
                 synchronized (Requester.this) {
                     subjects = streamInputMap.values();
                 }
@@ -958,7 +958,7 @@ public void onError(Throwable t) {
             }
 
             public void onComplete() {
-                Collection<UnicastSubject<Frame>> subjects = null;
+                Collection<UnicastSubject<Frame>> subjects;
                 synchronized (Requester.this) {
                     subjects = streamInputMap.values();
                 }
 
@@ -253,7 +253,7 @@ public void onNext(Frame requestFrame) {
 							responsePublisher = handleMetadataPush(
                                 requestFrame, requestHandler);
 						} else if (requestFrame.getType() == FrameType.CANCEL) {
-							Subscription s = null;
+							Subscription s;
 							synchronized (Responder.this) {
 								s = cancellationSubscriptions.get(requestFrame.getStreamId());
 							}
@@ -262,7 +262,7 @@ public void onNext(Frame requestFrame) {
 							}
 							return;
 						} else if (requestFrame.getType() == FrameType.REQUEST_N) {
-							SubscriptionArbiter inFlightSubscription = null;
+							SubscriptionArbiter inFlightSubscription;
 							synchronized (Responder.this) {
 								inFlightSubscription = inFlight.get(requestFrame.getStreamId());
 							}
@@ -693,7 +693,7 @@ private Publisher<Frame> handleRequestChannel(Frame requestFrame,
 			Int2ObjectHashMap<Subscription> cancellationSubscriptions,
 			Int2ObjectHashMap<SubscriptionArbiter> inFlight) {
 
-		UnicastSubject<Payload> channelSubject = null;
+		UnicastSubject<Payload> channelSubject;
 		synchronized(Responder.this) {
 			channelSubject = channels.get(requestFrame.getStreamId());
 		}
@@ -869,7 +869,7 @@ public void addTransportRequest(long n) {
 		}
 
 		private void tryRequest() {
-			long toRequest = 0;
+			long toRequest;
 			synchronized(this) {
 				if(applicationProducer == null) {
 					return;
 
@@ -47,7 +47,7 @@ public void clear() {
 
 	@Override
 	public void dispose() {
-		Disposable[] cs = null;
+		Disposable[] cs;
 		synchronized (this) {
 			disposed = true;
 			cs = resources.toArray(new Disposable[] {});
 
@@ -68,7 +68,7 @@ public synchronized void unregister(Responder responder) {
 
     @Override
     public synchronized boolean accept(Responder responder, Frame frame) {
-        boolean valid = false;
+        boolean valid;
         final Integer remainingTickets = responders.get(responder);
         return remainingTickets == null || remainingTickets > 0;
     }
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ public static Throwable from(Frame frame) {`
`31`	`31`	`message = new String(byteBuffer.array(), UTF_8);`
`32`	`32`	`}`
`33`	`33`
`34`		`- Throwable ex = null;`
	`34`	`+ Throwable ex;`
`35`	`35`	`switch (errorCode) {`
`36`	`36`	`case APPLICATION_ERROR:`
`37`	`37`	`ex = new ApplicationException(message);`
Original file line number	Diff line number	Diff line change
`@@ -947,7 +947,7 @@ public void onNext(Frame frame) {`
`947`	`947`	`}`
`948`	`948`
`949`	`949`	`public void onError(Throwable t) {`
`950`		`- Collection<UnicastSubject<Frame>> subjects = null;`
	`950`	`+ Collection<UnicastSubject<Frame>> subjects;`
`951`	`951`	`synchronized (Requester.this) {`
`952`	`952`	`subjects = streamInputMap.values();`
`953`	`953`	`}`
`@@ -958,7 +958,7 @@ public void onError(Throwable t) {`
`958`	`958`	`}`
`959`	`959`
`960`	`960`	`public void onComplete() {`
`961`		`- Collection<UnicastSubject<Frame>> subjects = null;`
	`961`	`+ Collection<UnicastSubject<Frame>> subjects;`
`962`	`962`	`synchronized (Requester.this) {`
`963`	`963`	`subjects = streamInputMap.values();`
`964`	`964`	`}`
Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ public synchronized void unregister(Responder responder) {`
`68`	`68`
`69`	`69`	`@Override`
`70`	`70`	`public synchronized boolean accept(Responder responder, Frame frame) {`
`71`		`- boolean valid = false;`
	`71`	`+ boolean valid;`
`72`	`72`	`final Integer remainingTickets = responders.get(responder);`
`73`	`73`	`return remainingTickets == null \|\| remainingTickets > 0;`
`74`	`74`	`}`