@@ -2,7 +2,6 @@ package com.lighttpd
2
2
3
3
import android.util.Log
4
4
import com.drpogodin.reactnativestaticserver.Errors
5
- import java.util.function.BiConsumer
6
5
7
6
/* *
8
7
* Java interface for native Lighttpd server running in a dedicated Thread.
@@ -25,7 +24,7 @@ class Server(
25
24
val id : Double ,
26
25
var configPath : String ,
27
26
var errlogPath : String ,
28
- private val signalConsumer : BiConsumer < String , String ?>
27
+ private val signalConsumer : (signal: String , message: String? ) -> Unit
29
28
) : Thread() {
30
29
override fun interrupt () {
31
30
Log .i(LOGTAG , " Server.interrupt() triggered" )
@@ -42,7 +41,7 @@ class Server(
42
41
if (activeServer != null ) {
43
42
val msg = " Another Server instance is active"
44
43
Log .e(LOGTAG , msg)
45
- signalConsumer.accept (CRASHED , msg)
44
+ signalConsumer(CRASHED , msg)
46
45
return
47
46
}
48
47
try {
@@ -56,11 +55,11 @@ class Server(
56
55
// signals.
57
56
activeServer = null
58
57
Log .i(LOGTAG , " Server terminated gracefully" )
59
- signalConsumer.accept (TERMINATED , null )
58
+ signalConsumer(TERMINATED , null )
60
59
} catch (error: Exception ) {
61
60
activeServer = null
62
61
Log .e(LOGTAG , " Server crashed" , error)
63
- signalConsumer.accept (CRASHED , error.message)
62
+ signalConsumer(CRASHED , error.message)
64
63
}
65
64
}
66
65
@@ -79,7 +78,7 @@ class Server(
79
78
// NOTE: @JvmStatic annotation is needed to make this function
80
79
// visible via JNI in C code.
81
80
@JvmStatic fun onLaunchedCallback () {
82
- activeServer!! .signalConsumer.accept (LAUNCHED , null )
81
+ activeServer!! .signalConsumer(LAUNCHED , null )
83
82
}
84
83
}
85
84
}
0 commit comments