Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlexander Kurtakov2018-10-30 07:29:54 +0000
committerAlexander Kurtakov2018-10-30 12:37:09 +0000
commit293a2626f262d8048c6667b56ca6348a83aefc91 (patch)
tree5188d7251ebd50a9399d7ec644f09c48b24125f2 /bundles/org.eclipse.jsch.core/src/org/eclipse/jsch/internal/core/ResponsiveSocketFactory.java
parenta6c8c68869fed5544105d9c25733be3a64b64ce1 (diff)
downloadeclipse.platform.team-293a2626f262d8048c6667b56ca6348a83aefc91.tar.gz
eclipse.platform.team-293a2626f262d8048c6667b56ca6348a83aefc91.tar.xz
eclipse.platform.team-293a2626f262d8048c6667b56ca6348a83aefc91.zip
Lambda conversions.
Change-Id: I82abbfbcfd6d7485cf76711d685f79030f5b7306 Signed-off-by: Alexander Kurtakov <akurtako@redhat.com>
Diffstat (limited to 'bundles/org.eclipse.jsch.core/src/org/eclipse/jsch/internal/core/ResponsiveSocketFactory.java')
-rw-r--r--bundles/org.eclipse.jsch.core/src/org/eclipse/jsch/internal/core/ResponsiveSocketFactory.java28
1 files changed, 13 insertions, 15 deletions
diff --git a/bundles/org.eclipse.jsch.core/src/org/eclipse/jsch/internal/core/ResponsiveSocketFactory.java b/bundles/org.eclipse.jsch.core/src/org/eclipse/jsch/internal/core/ResponsiveSocketFactory.java
index e472dc3e6..3f93d8fe6 100644
--- a/bundles/org.eclipse.jsch.core/src/org/eclipse/jsch/internal/core/ResponsiveSocketFactory.java
+++ b/bundles/org.eclipse.jsch.core/src/org/eclipse/jsch/internal/core/ResponsiveSocketFactory.java
@@ -69,23 +69,21 @@ public class ResponsiveSocketFactory implements SocketFactory {
// Start a thread to open a socket
final Socket[] socket = new Socket[] { null };
final Exception[] exception = new Exception[] {null };
- final Thread thread = new Thread(new Runnable() {
- public void run() {
- try {
- Socket newSocket = internalCreateSocket(host, port);
- synchronized (socket) {
- if (Thread.interrupted()) {
- // we we're either canceled or timed out so just close the socket
- newSocket.close();
- } else {
- socket[0] = newSocket;
- }
+ final Thread thread = new Thread(() -> {
+ try {
+ Socket newSocket = internalCreateSocket(host, port);
+ synchronized (socket) {
+ if (Thread.interrupted()) {
+ // we we're either canceled or timed out so just close the socket
+ newSocket.close();
+ } else {
+ socket[0] = newSocket;
}
- } catch (UnknownHostException e) {
- exception[0] = e;
- } catch (IOException e) {
- exception[0] = e;
}
+ } catch (UnknownHostException e1) {
+ exception[0] = e1;
+ } catch (IOException e2) {
+ exception[0] = e2;
}
});
thread.start();

Back to the top