mirror of
https://github.com/xpipe-io/xpipe.git
synced 2026-09-25 18:05:39 +00:00
Refactor
This commit is contained in:
@@ -6,6 +6,7 @@ import io.xpipe.beacon.util.QuietDialogHandler;
|
||||
import io.xpipe.core.store.InternalStreamStore;
|
||||
import io.xpipe.core.util.FailableBiConsumer;
|
||||
import io.xpipe.core.util.FailableConsumer;
|
||||
import lombok.Getter;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
@@ -13,6 +14,7 @@ import java.io.OutputStream;
|
||||
|
||||
public abstract class BeaconConnection implements AutoCloseable {
|
||||
|
||||
@Getter
|
||||
protected BeaconClient beaconClient;
|
||||
|
||||
private InputStream bodyInput;
|
||||
@@ -20,10 +22,6 @@ public abstract class BeaconConnection implements AutoCloseable {
|
||||
|
||||
protected abstract void constructSocket();
|
||||
|
||||
public BeaconClient getBeaconClient() {
|
||||
return beaconClient;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void close() {
|
||||
try {
|
||||
|
||||
@@ -16,7 +16,7 @@ public class MessageExchanges {
|
||||
if (ALL == null) {
|
||||
ALL = ServiceLoader.load(MessageExchange.class).stream()
|
||||
.map(s -> {
|
||||
return (MessageExchange) s.get();
|
||||
return s.get();
|
||||
})
|
||||
.collect(Collectors.toList());
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user