mirror of
https://github.com/PhotonVision/photonvision
synced 2026-07-05 03:21:40 +00:00
fix naming (#1089)
This commit is contained in:
@@ -135,7 +135,7 @@ public class NTDataPublisher implements CVPipelineResultConsumer {
|
|||||||
TrackedTarget.simpleFromTrackedTargets(result.targets),
|
TrackedTarget.simpleFromTrackedTargets(result.targets),
|
||||||
result.multiTagResult);
|
result.multiTagResult);
|
||||||
|
|
||||||
ts.resultPublisher.accept(simplified, simplified.getPacketSize());
|
ts.resultPublisher.set(simplified, simplified.getPacketSize());
|
||||||
if (ConfigManager.getInstance().getConfig().getNetworkConfig().shouldPublishProto) {
|
if (ConfigManager.getInstance().getConfig().getNetworkConfig().shouldPublishProto) {
|
||||||
ts.protoResultPublisher.set(simplified);
|
ts.protoResultPublisher.set(simplified);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -563,7 +563,7 @@ public class PhotonCameraSim implements AutoCloseable {
|
|||||||
public void submitProcessedFrame(PhotonPipelineResult result, long receiveTimestamp) {
|
public void submitProcessedFrame(PhotonPipelineResult result, long receiveTimestamp) {
|
||||||
ts.latencyMillisEntry.set(result.getLatencyMillis(), receiveTimestamp);
|
ts.latencyMillisEntry.set(result.getLatencyMillis(), receiveTimestamp);
|
||||||
|
|
||||||
ts.resultPublisher.accept(result, result.getPacketSize());
|
ts.resultPublisher.set(result, result.getPacketSize());
|
||||||
|
|
||||||
boolean hasTargets = result.hasTargets();
|
boolean hasTargets = result.hasTargets();
|
||||||
ts.hasTargetEntry.set(hasTargets, receiveTimestamp);
|
ts.hasTargetEntry.set(hasTargets, receiveTimestamp);
|
||||||
|
|||||||
@@ -143,7 +143,7 @@ public class SimPhotonCamera {
|
|||||||
PhotonPipelineResult newResult =
|
PhotonPipelineResult newResult =
|
||||||
new PhotonPipelineResult(latencyMillis, targetList, new MultiTargetPNPResult());
|
new PhotonPipelineResult(latencyMillis, targetList, new MultiTargetPNPResult());
|
||||||
|
|
||||||
ts.resultPublisher.accept(newResult, newResult.getPacketSize());
|
ts.resultPublisher.set(newResult, newResult.getPacketSize());
|
||||||
|
|
||||||
boolean hasTargets = newResult.hasTargets();
|
boolean hasTargets = newResult.hasTargets();
|
||||||
ts.hasTargetEntry.set(hasTargets);
|
ts.hasTargetEntry.set(hasTargets);
|
||||||
|
|||||||
@@ -30,14 +30,14 @@ public class PacketPublisher<T> implements AutoCloseable {
|
|||||||
this.serde = serde;
|
this.serde = serde;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void accept(T value, int byteSize) {
|
public void set(T value, int byteSize) {
|
||||||
var packet = new Packet(byteSize);
|
var packet = new Packet(byteSize);
|
||||||
serde.pack(packet, value);
|
serde.pack(packet, value);
|
||||||
publisher.set(packet.getData());
|
publisher.set(packet.getData());
|
||||||
}
|
}
|
||||||
|
|
||||||
public void accept(T value) {
|
public void set(T value) {
|
||||||
accept(value, serde.getMaxByteSize());
|
set(value, serde.getMaxByteSize());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
Reference in New Issue
Block a user