Skip to content

Commit d48f7d3

Browse files
authored
Add isActive to NetherNetSignaling (#13)
1 parent d89d0e9 commit d48f7d3

4 files changed

Lines changed: 17 additions & 1 deletion

File tree

‎gradle.properties‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
# Only update version on publishing to Maven Central
2-
version=1.7.3
2+
version=1.7.4

‎transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/AbstractNetherNetXboxSignaling.java‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -194,6 +194,12 @@ public void channelInactive(ChannelHandlerContext ctx) throws Exception {
194194
super.channelInactive(ctx);
195195
}
196196

197+
@Override
198+
public boolean isActive() {
199+
Channel ch = this.channel;
200+
return ch != null && ch.isActive();
201+
}
202+
197203
@Override
198204
public void close() {
199205
if (channel != null) channel.close();

‎transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetDiscoverySignaling.java‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,11 @@ public void setNotFoundHandler(NetherNetClientSignaling.NotFoundHandler handler)
164164
// Not implemented for Discovery signaling
165165
}
166166

167+
@Override
168+
public boolean isActive() {
169+
return this.discovery.isActive();
170+
}
171+
167172
@Override
168173
public void close() {
169174
this.discovery.close();

‎transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetSignaling.java‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,11 @@ public interface NetherNetSignaling extends AutoCloseable {
3333
*/
3434
String getLocalNetworkId();
3535

36+
/**
37+
* Whether the signaling is connected and able to carry messages
38+
*/
39+
boolean isActive();
40+
3641
/**
3742
* Closes the signaling channel and releases any associated resources.
3843
*/

0 commit comments

Comments
 (0)