Smikkelbakje/J1B4-Fitbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

But crack

Browse Source
This commit is contained in:
Luca Warmenhoven
2024-05-28 14:08:12 +02:00
parent 8c1e4332aa
commit d9c05b2975
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
code/src/Fitbot/app/src/main/java/com/example/fitbot/exercise/Exercise.java
View File

@@ -3,13 +3,14 @@ package com.example.fitbot.exercise;
import android.util.Log; import android.util.Log;
import com.example.fitbot.util.path.GesturePath; import com.example.fitbot.util.path.GesturePath;
import com.example.fitbot.util.processing.IMotionDataConsumer;
import com.example.fitbot.util.server.IWebServerHandler; import com.example.fitbot.util.server.IWebServerHandler;
import com.example.fitbot.util.server.WebServer; import com.example.fitbot.util.server.WebServer;
import java.util.Objects; import java.util.Objects;
import java.util.function.Consumer; import java.util.function.Consumer;
public class Exercise implements Consumer<String> { public class Exercise implements IWebServerHandler {
private EMuscleGroup muscleGroup; private EMuscleGroup muscleGroup;
private GesturePath path; private GesturePath path;
@@ -128,7 +129,7 @@ public class Exercise implements Consumer<String> {
} }
@Override @Override
public void accept(String message) { public void onReceive(String message) {
} }
} }

6
code/src/Fitbot/app/src/main/java/com/example/fitbot/util/server/WebServer.java
View File

@@ -17,7 +17,7 @@ import java.util.function.Consumer;
public class WebServer implements Runnable { public class WebServer implements Runnable {
private ServerSocket serverSocket; private ServerSocket serverSocket;
protected Consumer<String> eventHandler = (input) -> {}; // No-op. protected IWebServerHandler eventHandler = (input) -> {}; // No-op.
private Thread thread; private Thread thread;
private AtomicBoolean forceClose = new AtomicBoolean(false); private AtomicBoolean forceClose = new AtomicBoolean(false);
@@ -72,7 +72,7 @@ public class WebServer implements Runnable {
newSocket.close(); newSocket.close();
this.eventHandler.accept(builder.toString()); this.eventHandler.onReceive(builder.toString());
} catch (IOException error) { } catch (IOException error) {
String reason = error.getMessage() == null ? "Unknown reason" : error.getMessage(); String reason = error.getMessage() == null ? "Unknown reason" : error.getMessage();
@@ -105,7 +105,7 @@ public class WebServer implements Runnable {
* - onDisconnected(Socket) * - onDisconnected(Socket)
* - onError(Socket, String) * - onError(Socket, String)
*/ */
public void setEventHandler(Consumer<String> handler) { public void setEventHandler(IWebServerHandler handler) {
this.eventHandler = handler; this.eventHandler = handler;
} }