From 1263913c6b3fc841428744d53254ad4eaa0ee3e9 Mon Sep 17 00:00:00 2001 From: Benjamin Klum Date: Tue, 20 Aug 2024 15:53:01 +0200 Subject: [PATCH] cargo fmt --- .../infrastructure/plugin/backbone_shell.rs | 28 +- main/src/infrastructure/proto/generated.rs | 1451 ++++++----------- main/src/infrastructure/ui/app/app_library.rs | 20 +- swell-ui/src/window.rs | 14 +- 4 files changed, 515 insertions(+), 998 deletions(-) diff --git a/main/src/infrastructure/plugin/backbone_shell.rs b/main/src/infrastructure/plugin/backbone_shell.rs index d60ca2944..ca6844046 100644 --- a/main/src/infrastructure/plugin/backbone_shell.rs +++ b/main/src/infrastructure/plugin/backbone_shell.rs @@ -150,10 +150,10 @@ static APP_LIBRARY: std::sync::OnceLock; + RealearnAccelerator; pub type RealearnControlSurface = -MiddlewareControlSurface>; + MiddlewareControlSurface>; /// Just the old term as alias for easier class search. type _App = BackboneShell; @@ -921,7 +921,7 @@ impl BackboneShell { #[allow(dead_code)] pub fn spawn_in_async_runtime( &self, - f: impl Future + Send + 'static, + f: impl Future + Send + 'static, ) -> tokio::task::JoinHandle where R: Send + 'static, @@ -1048,7 +1048,7 @@ impl BackboneShell { self.controller_preset_manager.borrow().log_debug_info(); } - pub fn changed(&self) -> impl LocalObservable<'static, Item=(), Err=()> + 'static { + pub fn changed(&self) -> impl LocalObservable<'static, Item = (), Err = ()> + 'static { self.sessions_changed_subject.borrow().clone() } @@ -1228,7 +1228,7 @@ impl BackboneShell { .iter() .find(|i| i.is_main_unit && i.instance_id == instance_id) }) - .ok() + .ok() } #[cfg(feature = "playtime")] @@ -1922,7 +1922,7 @@ impl BackboneShell { compartment, target, ) - .or_else(|| self.find_first_session_with_target(None, compartment, target)) + .or_else(|| self.find_first_session_with_target(None, compartment, target)) } fn find_first_session_with_target( @@ -1977,7 +1977,7 @@ impl BackboneShell { Some(Reaper::get().current_project()), input_descriptor, ) - .or_else(|| self.find_first_session_with_input_from(None, input_descriptor)) + .or_else(|| self.find_first_session_with_input_from(None, input_descriptor)) } fn find_first_session_with_input_from( @@ -2002,13 +2002,13 @@ impl BackboneShell { compartment, capture_result, ) - .or_else(|| { - self.find_first_session_with_learnable_source_matching( - None, - compartment, - capture_result, - ) - }) + .or_else(|| { + self.find_first_session_with_learnable_source_matching( + None, + compartment, + capture_result, + ) + }) } fn find_first_session_with_learnable_source_matching( diff --git a/main/src/infrastructure/proto/generated.rs b/main/src/infrastructure/proto/generated.rs index f9711055a..f136578f0 100644 --- a/main/src/infrastructure/proto/generated.rs +++ b/main/src/infrastructure/proto/generated.rs @@ -116,9 +116,7 @@ pub mod command_request { #[prost(message, tag = "37")] GetOccasionalGlobalUpdates(super::GetOccasionalGlobalUpdatesRequest), #[prost(message, tag = "53")] - GetOccasionalPlaytimeEngineUpdates( - super::GetOccasionalPlaytimeEngineUpdatesRequest, - ), + GetOccasionalPlaytimeEngineUpdates(super::GetOccasionalPlaytimeEngineUpdatesRequest), #[prost(message, tag = "40")] GetOccasionalInstanceUpdates(super::GetOccasionalInstanceUpdatesRequest), #[prost(message, tag = "25")] @@ -282,9 +280,7 @@ pub mod event_reply { #[prost(message, tag = "1")] OccasionalGlobalUpdatesReply(super::GetOccasionalGlobalUpdatesReply), #[prost(message, tag = "15")] - OccasionalPlaytimeEngineUpdatesReply( - super::GetOccasionalPlaytimeEngineUpdatesReply, - ), + OccasionalPlaytimeEngineUpdatesReply(super::GetOccasionalPlaytimeEngineUpdatesReply), #[prost(message, tag = "13")] OccasionalInstanceUpdatesReply(super::GetOccasionalInstanceUpdatesReply), #[prost(message, tag = "14")] @@ -1783,15 +1779,9 @@ impl TriggerInstanceAction { TriggerInstanceAction::ArrangementTogglePlayStop => { "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_TOGGLE_PLAY_STOP" } - TriggerInstanceAction::ArrangementPlay => { - "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_PLAY" - } - TriggerInstanceAction::ArrangementStop => { - "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_STOP" - } - TriggerInstanceAction::ArrangementPause => { - "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_PAUSE" - } + TriggerInstanceAction::ArrangementPlay => "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_PLAY", + TriggerInstanceAction::ArrangementStop => "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_STOP", + TriggerInstanceAction::ArrangementPause => "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_PAUSE", TriggerInstanceAction::ArrangementStartRecording => { "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_START_RECORDING" } @@ -1806,9 +1796,7 @@ impl TriggerInstanceAction { /// Creates an enum from field names used in the ProtoBuf definition. pub fn from_str_name(value: &str) -> ::core::option::Option { match value { - "TRIGGER_INSTANCE_ACTION_SHOW_HELGOBOX_PLUGIN" => { - Some(Self::ShowHelgoboxPlugin) - } + "TRIGGER_INSTANCE_ACTION_SHOW_HELGOBOX_PLUGIN" => Some(Self::ShowHelgoboxPlugin), "TRIGGER_INSTANCE_ACTION_ARRANGEMENT_TOGGLE_PLAY_STOP" => { Some(Self::ArrangementTogglePlayStop) } @@ -2148,9 +2136,7 @@ impl TriggerTrackAction { TriggerTrackAction::ToggleArm => "TRIGGER_TRACK_ACTION_TOGGLE_ARM", TriggerTrackAction::ShowFx => "TRIGGER_TRACK_ACTION_SHOW_FX", TriggerTrackAction::ShowRouting => "TRIGGER_TRACK_ACTION_SHOW_ROUTING", - TriggerTrackAction::ToggleLearnInput => { - "TRIGGER_TRACK_ACTION_TOGGLE_LEARN_INPUT" - } + TriggerTrackAction::ToggleLearnInput => "TRIGGER_TRACK_ACTION_TOGGLE_LEARN_INPUT", } } /// Creates an enum from field names used in the ProtoBuf definition. @@ -2203,9 +2189,7 @@ impl TriggerColumnAction { "TRIGGER_COLUMN_ACTION_REMOVE_SIMPLE_MAPPING" } TriggerColumnAction::Activate => "TRIGGER_COLUMN_ACTION_ACTIVATE", - TriggerColumnAction::ExportToClipboard => { - "TRIGGER_COLUMN_ACTION_EXPORT_TO_CLIPBOARD" - } + TriggerColumnAction::ExportToClipboard => "TRIGGER_COLUMN_ACTION_EXPORT_TO_CLIPBOARD", TriggerColumnAction::ExportToArrangement => { "TRIGGER_COLUMN_ACTION_EXPORT_TO_ARRANGEMENT" } @@ -2225,14 +2209,10 @@ impl TriggerColumnAction { "TRIGGER_COLUMN_ACTION_TOGGLE_LEARN_SIMPLE_MAPPING" => { Some(Self::ToggleLearnSimpleMapping) } - "TRIGGER_COLUMN_ACTION_REMOVE_SIMPLE_MAPPING" => { - Some(Self::RemoveSimpleMapping) - } + "TRIGGER_COLUMN_ACTION_REMOVE_SIMPLE_MAPPING" => Some(Self::RemoveSimpleMapping), "TRIGGER_COLUMN_ACTION_ACTIVATE" => Some(Self::Activate), "TRIGGER_COLUMN_ACTION_EXPORT_TO_CLIPBOARD" => Some(Self::ExportToClipboard), - "TRIGGER_COLUMN_ACTION_EXPORT_TO_ARRANGEMENT" => { - Some(Self::ExportToArrangement) - } + "TRIGGER_COLUMN_ACTION_EXPORT_TO_ARRANGEMENT" => Some(Self::ExportToArrangement), _ => None, } } @@ -2274,16 +2254,12 @@ impl TriggerRowAction { TriggerRowAction::ToggleLearnSimpleMapping => { "TRIGGER_ROW_ACTION_TOGGLE_LEARN_SIMPLE_MAPPING" } - TriggerRowAction::RemoveSimpleMapping => { - "TRIGGER_ROW_ACTION_REMOVE_SIMPLE_MAPPING" - } + TriggerRowAction::RemoveSimpleMapping => "TRIGGER_ROW_ACTION_REMOVE_SIMPLE_MAPPING", TriggerRowAction::BuildSceneFromPlayingSlots => { "TRIGGER_ROW_ACTION_BUILD_SCENE_FROM_PLAYING_SLOTS" } TriggerRowAction::Activate => "TRIGGER_ROW_ACTION_ACTIVATE", - TriggerRowAction::ExportToArrangement => { - "TRIGGER_ROW_ACTION_EXPORT_TO_ARRANGEMENT" - } + TriggerRowAction::ExportToArrangement => "TRIGGER_ROW_ACTION_EXPORT_TO_ARRANGEMENT", } } /// Creates an enum from field names used in the ProtoBuf definition. @@ -2398,28 +2374,18 @@ impl TriggerSlotAction { TriggerSlotAction::Copy => "TRIGGER_SLOT_ACTION_COPY", TriggerSlotAction::Cut => "TRIGGER_SLOT_ACTION_CUT", TriggerSlotAction::Paste => "TRIGGER_SLOT_ACTION_PASTE", - TriggerSlotAction::ImportSelectedItems => { - "TRIGGER_SLOT_ACTION_IMPORT_SELECTED_ITEMS" - } + TriggerSlotAction::ImportSelectedItems => "TRIGGER_SLOT_ACTION_IMPORT_SELECTED_ITEMS", TriggerSlotAction::Panic => "TRIGGER_SLOT_ACTION_PANIC", - TriggerSlotAction::CreateEmptyMidiClip => { - "TRIGGER_SLOT_ACTION_CREATE_EMPTY_MIDI_CLIP" - } + TriggerSlotAction::CreateEmptyMidiClip => "TRIGGER_SLOT_ACTION_CREATE_EMPTY_MIDI_CLIP", TriggerSlotAction::ToggleLearnSimpleMapping => { "TRIGGER_SLOT_ACTION_TOGGLE_LEARN_SIMPLE_MAPPING" } - TriggerSlotAction::RemoveSimpleMapping => { - "TRIGGER_SLOT_ACTION_REMOVE_SIMPLE_MAPPING" - } + TriggerSlotAction::RemoveSimpleMapping => "TRIGGER_SLOT_ACTION_REMOVE_SIMPLE_MAPPING", TriggerSlotAction::TriggerOn => "TRIGGER_SLOT_ACTION_TRIGGER_ON", TriggerSlotAction::TriggerOff => "TRIGGER_SLOT_ACTION_TRIGGER_OFF", TriggerSlotAction::Activate => "TRIGGER_SLOT_ACTION_ACTIVATE", - TriggerSlotAction::ExportToClipboard => { - "TRIGGER_SLOT_ACTION_EXPORT_TO_CLIPBOARD" - } - TriggerSlotAction::ExportToArrangement => { - "TRIGGER_SLOT_ACTION_EXPORT_TO_ARRANGEMENT" - } + TriggerSlotAction::ExportToClipboard => "TRIGGER_SLOT_ACTION_EXPORT_TO_CLIPBOARD", + TriggerSlotAction::ExportToArrangement => "TRIGGER_SLOT_ACTION_EXPORT_TO_ARRANGEMENT", } } /// Creates an enum from field names used in the ProtoBuf definition. @@ -2432,26 +2398,18 @@ impl TriggerSlotAction { "TRIGGER_SLOT_ACTION_COPY" => Some(Self::Copy), "TRIGGER_SLOT_ACTION_CUT" => Some(Self::Cut), "TRIGGER_SLOT_ACTION_PASTE" => Some(Self::Paste), - "TRIGGER_SLOT_ACTION_IMPORT_SELECTED_ITEMS" => { - Some(Self::ImportSelectedItems) - } + "TRIGGER_SLOT_ACTION_IMPORT_SELECTED_ITEMS" => Some(Self::ImportSelectedItems), "TRIGGER_SLOT_ACTION_PANIC" => Some(Self::Panic), - "TRIGGER_SLOT_ACTION_CREATE_EMPTY_MIDI_CLIP" => { - Some(Self::CreateEmptyMidiClip) - } + "TRIGGER_SLOT_ACTION_CREATE_EMPTY_MIDI_CLIP" => Some(Self::CreateEmptyMidiClip), "TRIGGER_SLOT_ACTION_TOGGLE_LEARN_SIMPLE_MAPPING" => { Some(Self::ToggleLearnSimpleMapping) } - "TRIGGER_SLOT_ACTION_REMOVE_SIMPLE_MAPPING" => { - Some(Self::RemoveSimpleMapping) - } + "TRIGGER_SLOT_ACTION_REMOVE_SIMPLE_MAPPING" => Some(Self::RemoveSimpleMapping), "TRIGGER_SLOT_ACTION_TRIGGER_ON" => Some(Self::TriggerOn), "TRIGGER_SLOT_ACTION_TRIGGER_OFF" => Some(Self::TriggerOff), "TRIGGER_SLOT_ACTION_ACTIVATE" => Some(Self::Activate), "TRIGGER_SLOT_ACTION_EXPORT_TO_CLIPBOARD" => Some(Self::ExportToClipboard), - "TRIGGER_SLOT_ACTION_EXPORT_TO_ARRANGEMENT" => { - Some(Self::ExportToArrangement) - } + "TRIGGER_SLOT_ACTION_EXPORT_TO_ARRANGEMENT" => Some(Self::ExportToArrangement), _ => None, } } @@ -2481,20 +2439,12 @@ impl TriggerClipAction { TriggerClipAction::Edit => "TRIGGER_CLIP_ACTION_EDIT", TriggerClipAction::Remove => "TRIGGER_CLIP_ACTION_REMOVE", TriggerClipAction::Promote => "TRIGGER_CLIP_ACTION_PROMOTE", - TriggerClipAction::OpenInMediaExplorer => { - "TRIGGER_CLIP_ACTION_OPEN_IN_MEDIA_EXPLORER" - } + TriggerClipAction::OpenInMediaExplorer => "TRIGGER_CLIP_ACTION_OPEN_IN_MEDIA_EXPLORER", TriggerClipAction::Quantize => "TRIGGER_CLIP_ACTION_QUANTIZE", TriggerClipAction::Unquantize => "TRIGGER_CLIP_ACTION_UNQUANTIZE", - TriggerClipAction::ExportToClipboard => { - "TRIGGER_CLIP_ACTION_EXPORT_TO_CLIPBOARD" - } - TriggerClipAction::ExportToArrangement => { - "TRIGGER_CLIP_ACTION_EXPORT_TO_ARRANGEMENT" - } - TriggerClipAction::ToggleMidiOverdub => { - "TRIGGER_CLIP_ACTION_TOGGLE_MIDI_OVERDUB" - } + TriggerClipAction::ExportToClipboard => "TRIGGER_CLIP_ACTION_EXPORT_TO_CLIPBOARD", + TriggerClipAction::ExportToArrangement => "TRIGGER_CLIP_ACTION_EXPORT_TO_ARRANGEMENT", + TriggerClipAction::ToggleMidiOverdub => "TRIGGER_CLIP_ACTION_TOGGLE_MIDI_OVERDUB", } } /// Creates an enum from field names used in the ProtoBuf definition. @@ -2504,15 +2454,11 @@ impl TriggerClipAction { "TRIGGER_CLIP_ACTION_EDIT" => Some(Self::Edit), "TRIGGER_CLIP_ACTION_REMOVE" => Some(Self::Remove), "TRIGGER_CLIP_ACTION_PROMOTE" => Some(Self::Promote), - "TRIGGER_CLIP_ACTION_OPEN_IN_MEDIA_EXPLORER" => { - Some(Self::OpenInMediaExplorer) - } + "TRIGGER_CLIP_ACTION_OPEN_IN_MEDIA_EXPLORER" => Some(Self::OpenInMediaExplorer), "TRIGGER_CLIP_ACTION_QUANTIZE" => Some(Self::Quantize), "TRIGGER_CLIP_ACTION_UNQUANTIZE" => Some(Self::Unquantize), "TRIGGER_CLIP_ACTION_EXPORT_TO_CLIPBOARD" => Some(Self::ExportToClipboard), - "TRIGGER_CLIP_ACTION_EXPORT_TO_ARRANGEMENT" => { - Some(Self::ExportToArrangement) - } + "TRIGGER_CLIP_ACTION_EXPORT_TO_ARRANGEMENT" => Some(Self::ExportToArrangement), "TRIGGER_CLIP_ACTION_TOGGLE_MIDI_OVERDUB" => Some(Self::ToggleMidiOverdub), _ => None, } @@ -2705,17 +2651,11 @@ impl SlotPlayState { SlotPlayState::Unknown => "SLOT_PLAY_STATE_UNKNOWN", SlotPlayState::Stopped => "SLOT_PLAY_STATE_STOPPED", SlotPlayState::Ignited => "SLOT_PLAY_STATE_IGNITED", - SlotPlayState::ScheduledForPlayStart => { - "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_START" - } + SlotPlayState::ScheduledForPlayStart => "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_START", SlotPlayState::Playing => "SLOT_PLAY_STATE_PLAYING", SlotPlayState::Paused => "SLOT_PLAY_STATE_PAUSED", - SlotPlayState::ScheduledForPlayRestart => { - "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_RESTART" - } - SlotPlayState::ScheduledForPlayStop => { - "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_STOP" - } + SlotPlayState::ScheduledForPlayRestart => "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_RESTART", + SlotPlayState::ScheduledForPlayStop => "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_STOP", SlotPlayState::ScheduledForRecordingStart => { "SLOT_PLAY_STATE_SCHEDULED_FOR_RECORDING_START" } @@ -2731,22 +2671,16 @@ impl SlotPlayState { "SLOT_PLAY_STATE_UNKNOWN" => Some(Self::Unknown), "SLOT_PLAY_STATE_STOPPED" => Some(Self::Stopped), "SLOT_PLAY_STATE_IGNITED" => Some(Self::Ignited), - "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_START" => { - Some(Self::ScheduledForPlayStart) - } + "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_START" => Some(Self::ScheduledForPlayStart), "SLOT_PLAY_STATE_PLAYING" => Some(Self::Playing), "SLOT_PLAY_STATE_PAUSED" => Some(Self::Paused), - "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_RESTART" => { - Some(Self::ScheduledForPlayRestart) - } + "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_RESTART" => Some(Self::ScheduledForPlayRestart), "SLOT_PLAY_STATE_SCHEDULED_FOR_PLAY_STOP" => Some(Self::ScheduledForPlayStop), "SLOT_PLAY_STATE_SCHEDULED_FOR_RECORDING_START" => { Some(Self::ScheduledForRecordingStart) } "SLOT_PLAY_STATE_RECORDING" => Some(Self::Recording), - "SLOT_PLAY_STATE_SCHEDULED_FOR_RECORDING_STOP" => { - Some(Self::ScheduledForRecordingStop) - } + "SLOT_PLAY_STATE_SCHEDULED_FOR_RECORDING_STOP" => Some(Self::ScheduledForRecordingStop), _ => None, } } @@ -2766,9 +2700,7 @@ impl MidiDeviceStatus { pub fn as_str_name(&self) -> &'static str { match self { MidiDeviceStatus::Disconnected => "MIDI_DEVICE_STATUS_DISCONNECTED", - MidiDeviceStatus::ConnectedButDisabled => { - "MIDI_DEVICE_STATUS_CONNECTED_BUT_DISABLED" - } + MidiDeviceStatus::ConnectedButDisabled => "MIDI_DEVICE_STATUS_CONNECTED_BUT_DISABLED", MidiDeviceStatus::Connected => "MIDI_DEVICE_STATUS_CONNECTED", } } @@ -2776,9 +2708,7 @@ impl MidiDeviceStatus { pub fn from_str_name(value: &str) -> ::core::option::Option { match value { "MIDI_DEVICE_STATUS_DISCONNECTED" => Some(Self::Disconnected), - "MIDI_DEVICE_STATUS_CONNECTED_BUT_DISABLED" => { - Some(Self::ConnectedButDisabled) - } + "MIDI_DEVICE_STATUS_CONNECTED_BUT_DISABLED" => Some(Self::ConnectedButDisabled), "MIDI_DEVICE_STATUS_CONNECTED" => Some(Self::Connected), _ => None, } @@ -2804,13 +2734,9 @@ impl ArrangementPlayState { ArrangementPlayState::Unknown => "ARRANGEMENT_PLAY_STATE_UNKNOWN", ArrangementPlayState::Stopped => "ARRANGEMENT_PLAY_STATE_STOPPED", ArrangementPlayState::Playing => "ARRANGEMENT_PLAY_STATE_PLAYING", - ArrangementPlayState::PlayingPaused => { - "ARRANGEMENT_PLAY_STATE_PLAYING_PAUSED" - } + ArrangementPlayState::PlayingPaused => "ARRANGEMENT_PLAY_STATE_PLAYING_PAUSED", ArrangementPlayState::Recording => "ARRANGEMENT_PLAY_STATE_RECORDING", - ArrangementPlayState::RecordingPaused => { - "ARRANGEMENT_PLAY_STATE_RECORDING_PAUSED" - } + ArrangementPlayState::RecordingPaused => "ARRANGEMENT_PLAY_STATE_RECORDING_PAUSED", } } /// Creates an enum from field names used in the ProtoBuf definition. @@ -2869,63 +2795,39 @@ pub mod helgobox_service_server { async fn get_host_info( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; async fn prove_authenticity( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; async fn get_app_settings( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// General instance queries async fn get_custom_instance_data( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// Playtime matrix queries async fn get_project_dir( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; async fn get_arrangement_info( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// Playtime clip queries async fn get_clip_detail( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// ReaLearn compartment queries async fn get_compartment_data( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// General global commands async fn trigger_global( &self, @@ -3107,12 +3009,8 @@ pub mod helgobox_service_server { ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the GetOccasionalGlobalUpdates method. type GetOccasionalGlobalUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalGlobalUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// General global events async fn get_occasional_global_updates( @@ -3128,8 +3026,7 @@ pub mod helgobox_service_server { super::GetOccasionalPlaytimeEngineUpdatesReply, tonic::Status, >, - > - + Send + > + Send + 'static; /// Playtime global events async fn get_occasional_playtime_engine_updates( @@ -3141,12 +3038,8 @@ pub mod helgobox_service_server { >; /// Server streaming response type for the GetOccasionalInstanceUpdates method. type GetOccasionalInstanceUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalInstanceUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// General instance events async fn get_occasional_instance_updates( @@ -3158,28 +3051,17 @@ pub mod helgobox_service_server { >; /// Server streaming response type for the GetOccasionalUnitUpdates method. type GetOccasionalUnitUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalUnitUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; async fn get_occasional_unit_updates( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the GetOccasionalMatrixUpdates method. type GetOccasionalMatrixUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalMatrixUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// Playtime matrix events async fn get_occasional_matrix_updates( @@ -3191,12 +3073,8 @@ pub mod helgobox_service_server { >; /// Server streaming response type for the GetContinuousMatrixUpdates method. type GetContinuousMatrixUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetContinuousMatrixUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; async fn get_continuous_matrix_updates( &self, @@ -3207,12 +3085,8 @@ pub mod helgobox_service_server { >; /// Server streaming response type for the GetOccasionalColumnUpdates method. type GetOccasionalColumnUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalColumnUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// Playtime column events async fn get_occasional_column_updates( @@ -3224,12 +3098,8 @@ pub mod helgobox_service_server { >; /// Server streaming response type for the GetContinuousColumnUpdates method. type GetContinuousColumnUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetContinuousColumnUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; async fn get_continuous_column_updates( &self, @@ -3240,12 +3110,8 @@ pub mod helgobox_service_server { >; /// Server streaming response type for the GetOccasionalTrackUpdates method. type GetOccasionalTrackUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalTrackUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// Playtime track events async fn get_occasional_track_updates( @@ -3257,71 +3123,43 @@ pub mod helgobox_service_server { >; /// Server streaming response type for the GetOccasionalRowUpdates method. type GetOccasionalRowUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalRowUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// Playtime row events async fn get_occasional_row_updates( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the GetOccasionalSlotUpdates method. type GetOccasionalSlotUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalSlotUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// Playtime slot events async fn get_occasional_slot_updates( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the GetContinuousSlotUpdates method. type GetContinuousSlotUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetContinuousSlotUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; async fn get_continuous_slot_updates( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the GetOccasionalClipUpdates method. type GetOccasionalClipUpdatesStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::GetOccasionalClipUpdatesReply, - tonic::Status, - >, - > - + Send + Item = std::result::Result, + > + Send + 'static; /// Playtime clip events async fn get_occasional_clip_updates( &self, request: tonic::Request, - ) -> std::result::Result< - tonic::Response, - tonic::Status, - >; + ) -> std::result::Result, tonic::Status>; } #[derive(Debug)] pub struct HelgoboxServiceServer { @@ -3346,10 +3184,7 @@ pub mod helgobox_service_server { max_encoding_message_size: None, } } - pub fn with_interceptor( - inner: T, - interceptor: F, - ) -> InterceptedService + pub fn with_interceptor(inner: T, interceptor: F) -> InterceptedService where F: tonic::service::Interceptor, { @@ -3405,15 +3240,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetHostInfo" => { #[allow(non_camel_case_types)] struct GetHostInfoSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for GetHostInfoSvc { + impl tonic::server::UnaryService + for GetHostInfoSvc + { type Response = super::GetHostInfoReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -3451,23 +3282,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/ProveAuthenticity" => { #[allow(non_camel_case_types)] struct ProveAuthenticitySvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for ProveAuthenticitySvc { + impl + tonic::server::UnaryService + for ProveAuthenticitySvc + { type Response = super::ProveAuthenticityReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::prove_authenticity(&inner, request) - .await + ::prove_authenticity(&inner, request).await }; Box::pin(fut) } @@ -3498,23 +3325,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetAppSettings" => { #[allow(non_camel_case_types)] struct GetAppSettingsSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for GetAppSettingsSvc { + impl + tonic::server::UnaryService + for GetAppSettingsSvc + { type Response = super::GetAppSettingsReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_app_settings(&inner, request) - .await + ::get_app_settings(&inner, request).await }; Box::pin(fut) } @@ -3545,25 +3368,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetCustomInstanceData" => { #[allow(non_camel_case_types)] struct GetCustomInstanceDataSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for GetCustomInstanceDataSvc { + impl + tonic::server::UnaryService + for GetCustomInstanceDataSvc + { type Response = super::GetCustomInstanceDataReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_custom_instance_data( - &inner, - request, - ) + ::get_custom_instance_data(&inner, request) .await }; Box::pin(fut) @@ -3595,23 +3412,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetProjectDir" => { #[allow(non_camel_case_types)] struct GetProjectDirSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for GetProjectDirSvc { + impl + tonic::server::UnaryService + for GetProjectDirSvc + { type Response = super::GetProjectDirReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_project_dir(&inner, request) - .await + ::get_project_dir(&inner, request).await }; Box::pin(fut) } @@ -3642,26 +3455,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetArrangementInfo" => { #[allow(non_camel_case_types)] struct GetArrangementInfoSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for GetArrangementInfoSvc { + impl + tonic::server::UnaryService + for GetArrangementInfoSvc + { type Response = super::GetArrangementInfoReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_arrangement_info( - &inner, - request, - ) - .await + ::get_arrangement_info(&inner, request).await }; Box::pin(fut) } @@ -3692,23 +3498,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetClipDetail" => { #[allow(non_camel_case_types)] struct GetClipDetailSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for GetClipDetailSvc { + impl + tonic::server::UnaryService + for GetClipDetailSvc + { type Response = super::GetClipDetailReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_clip_detail(&inner, request) - .await + ::get_clip_detail(&inner, request).await }; Box::pin(fut) } @@ -3739,26 +3541,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetCompartmentData" => { #[allow(non_camel_case_types)] struct GetCompartmentDataSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for GetCompartmentDataSvc { + impl + tonic::server::UnaryService + for GetCompartmentDataSvc + { type Response = super::GetCompartmentDataReply; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_compartment_data( - &inner, - request, - ) - .await + ::get_compartment_data(&inner, request).await }; Box::pin(fut) } @@ -3789,23 +3584,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerGlobal" => { #[allow(non_camel_case_types)] struct TriggerGlobalSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerGlobalSvc { + impl + tonic::server::UnaryService + for TriggerGlobalSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::trigger_global(&inner, request) - .await + ::trigger_global(&inner, request).await }; Box::pin(fut) } @@ -3836,23 +3627,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetAppSettings" => { #[allow(non_camel_case_types)] struct SetAppSettingsSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetAppSettingsSvc { + impl + tonic::server::UnaryService + for SetAppSettingsSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_app_settings(&inner, request) - .await + ::set_app_settings(&inner, request).await }; Box::pin(fut) } @@ -3883,15 +3670,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/AddLicense" => { #[allow(non_camel_case_types)] struct AddLicenseSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for AddLicenseSvc { + impl tonic::server::UnaryService + for AddLicenseSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -3929,23 +3712,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SaveController" => { #[allow(non_camel_case_types)] struct SaveControllerSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SaveControllerSvc { + impl + tonic::server::UnaryService + for SaveControllerSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::save_controller(&inner, request) - .await + ::save_controller(&inner, request).await }; Box::pin(fut) } @@ -3976,23 +3755,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/DeleteController" => { #[allow(non_camel_case_types)] struct DeleteControllerSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for DeleteControllerSvc { + impl + tonic::server::UnaryService + for DeleteControllerSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::delete_controller(&inner, request) - .await + ::delete_controller(&inner, request).await }; Box::pin(fut) } @@ -4023,29 +3798,22 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetPlaytimeEngineSettings" => { #[allow(non_camel_case_types)] struct SetPlaytimeEngineSettingsSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService< - super::SetPlaytimeEngineSettingsRequest, - > for SetPlaytimeEngineSettingsSvc { + impl + tonic::server::UnaryService + for SetPlaytimeEngineSettingsSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::SetPlaytimeEngineSettingsRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::set_playtime_engine_settings( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -4076,23 +3844,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerInstance" => { #[allow(non_camel_case_types)] struct TriggerInstanceSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerInstanceSvc { + impl + tonic::server::UnaryService + for TriggerInstanceSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::trigger_instance(&inner, request) - .await + ::trigger_instance(&inner, request).await }; Box::pin(fut) } @@ -4123,26 +3887,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetInstanceSettings" => { #[allow(non_camel_case_types)] struct SetInstanceSettingsSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetInstanceSettingsSvc { + impl + tonic::server::UnaryService + for SetInstanceSettingsSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_instance_settings( - &inner, - request, - ) - .await + ::set_instance_settings(&inner, request).await }; Box::pin(fut) } @@ -4173,25 +3930,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetCustomInstanceData" => { #[allow(non_camel_case_types)] struct SetCustomInstanceDataSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetCustomInstanceDataSvc { + impl + tonic::server::UnaryService + for SetCustomInstanceDataSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_custom_instance_data( - &inner, - request, - ) + ::set_custom_instance_data(&inner, request) .await }; Box::pin(fut) @@ -4223,23 +3974,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerMatrix" => { #[allow(non_camel_case_types)] struct TriggerMatrixSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerMatrixSvc { + impl + tonic::server::UnaryService + for TriggerMatrixSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::trigger_matrix(&inner, request) - .await + ::trigger_matrix(&inner, request).await }; Box::pin(fut) } @@ -4270,23 +4017,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetMatrixSettings" => { #[allow(non_camel_case_types)] struct SetMatrixSettingsSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetMatrixSettingsSvc { + impl + tonic::server::UnaryService + for SetMatrixSettingsSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_matrix_settings(&inner, request) - .await + ::set_matrix_settings(&inner, request).await }; Box::pin(fut) } @@ -4317,23 +4060,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetMatrixTempo" => { #[allow(non_camel_case_types)] struct SetMatrixTempoSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetMatrixTempoSvc { + impl + tonic::server::UnaryService + for SetMatrixTempoSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_matrix_tempo(&inner, request) - .await + ::set_matrix_tempo(&inner, request).await }; Box::pin(fut) } @@ -4364,25 +4103,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetMatrixTimeSignature" => { #[allow(non_camel_case_types)] struct SetMatrixTimeSignatureSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetMatrixTimeSignatureSvc { + impl + tonic::server::UnaryService + for SetMatrixTimeSignatureSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_matrix_time_signature( - &inner, - request, - ) + ::set_matrix_time_signature(&inner, request) .await }; Box::pin(fut) @@ -4414,26 +4147,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetMatrixPlayRate" => { #[allow(non_camel_case_types)] struct SetMatrixPlayRateSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetMatrixPlayRateSvc { + impl + tonic::server::UnaryService + for SetMatrixPlayRateSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_matrix_play_rate( - &inner, - request, - ) - .await + ::set_matrix_play_rate(&inner, request).await }; Box::pin(fut) } @@ -4464,23 +4190,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetMatrixVolume" => { #[allow(non_camel_case_types)] struct SetMatrixVolumeSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetMatrixVolumeSvc { + impl + tonic::server::UnaryService + for SetMatrixVolumeSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_matrix_volume(&inner, request) - .await + ::set_matrix_volume(&inner, request).await }; Box::pin(fut) } @@ -4511,23 +4233,18 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetMatrixPan" => { #[allow(non_camel_case_types)] struct SetMatrixPanSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetMatrixPanSvc { + impl tonic::server::UnaryService + for SetMatrixPanSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_matrix_pan(&inner, request) - .await + ::set_matrix_pan(&inner, request).await }; Box::pin(fut) } @@ -4558,23 +4275,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerColumn" => { #[allow(non_camel_case_types)] struct TriggerColumnSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerColumnSvc { + impl + tonic::server::UnaryService + for TriggerColumnSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::trigger_column(&inner, request) - .await + ::trigger_column(&inner, request).await }; Box::pin(fut) } @@ -4605,23 +4318,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/InsertColumns" => { #[allow(non_camel_case_types)] struct InsertColumnsSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for InsertColumnsSvc { + impl + tonic::server::UnaryService + for InsertColumnsSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::insert_columns(&inner, request) - .await + ::insert_columns(&inner, request).await }; Box::pin(fut) } @@ -4652,23 +4361,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetColumnSettings" => { #[allow(non_camel_case_types)] struct SetColumnSettingsSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetColumnSettingsSvc { + impl + tonic::server::UnaryService + for SetColumnSettingsSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_column_settings(&inner, request) - .await + ::set_column_settings(&inner, request).await }; Box::pin(fut) } @@ -4699,23 +4404,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetColumnTrack" => { #[allow(non_camel_case_types)] struct SetColumnTrackSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetColumnTrackSvc { + impl + tonic::server::UnaryService + for SetColumnTrackSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_column_track(&inner, request) - .await + ::set_column_track(&inner, request).await }; Box::pin(fut) } @@ -4746,15 +4447,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/DragColumn" => { #[allow(non_camel_case_types)] struct DragColumnSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for DragColumnSvc { + impl tonic::server::UnaryService + for DragColumnSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -4792,15 +4489,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerTrack" => { #[allow(non_camel_case_types)] struct TriggerTrackSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerTrackSvc { + impl tonic::server::UnaryService + for TriggerTrackSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -4838,23 +4531,18 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetTrackName" => { #[allow(non_camel_case_types)] struct SetTrackNameSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetTrackNameSvc { + impl tonic::server::UnaryService + for SetTrackNameSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_track_name(&inner, request) - .await + ::set_track_name(&inner, request).await }; Box::pin(fut) } @@ -4885,23 +4573,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetTrackColor" => { #[allow(non_camel_case_types)] struct SetTrackColorSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetTrackColorSvc { + impl + tonic::server::UnaryService + for SetTrackColorSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_track_color(&inner, request) - .await + ::set_track_color(&inner, request).await }; Box::pin(fut) } @@ -4932,23 +4616,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetTrackInput" => { #[allow(non_camel_case_types)] struct SetTrackInputSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetTrackInputSvc { + impl + tonic::server::UnaryService + for SetTrackInputSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_track_input(&inner, request) - .await + ::set_track_input(&inner, request).await }; Box::pin(fut) } @@ -4979,27 +4659,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetTrackInputMonitoring" => { #[allow(non_camel_case_types)] struct SetTrackInputMonitoringSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetTrackInputMonitoringSvc { + impl + tonic::server::UnaryService + for SetTrackInputMonitoringSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::SetTrackInputMonitoringRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_track_input_monitoring( - &inner, - request, - ) + ::set_track_input_monitoring(&inner, request) .await }; Box::pin(fut) @@ -5031,23 +4703,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetTrackVolume" => { #[allow(non_camel_case_types)] struct SetTrackVolumeSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetTrackVolumeSvc { + impl + tonic::server::UnaryService + for SetTrackVolumeSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_track_volume(&inner, request) - .await + ::set_track_volume(&inner, request).await }; Box::pin(fut) } @@ -5078,15 +4746,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetTrackPan" => { #[allow(non_camel_case_types)] struct SetTrackPanSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetTrackPanSvc { + impl tonic::server::UnaryService + for SetTrackPanSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5124,15 +4788,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/OpenTrackFx" => { #[allow(non_camel_case_types)] struct OpenTrackFxSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for OpenTrackFxSvc { + impl tonic::server::UnaryService + for OpenTrackFxSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5170,15 +4830,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerRow" => { #[allow(non_camel_case_types)] struct TriggerRowSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerRowSvc { + impl tonic::server::UnaryService + for TriggerRowSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5216,15 +4872,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetRowData" => { #[allow(non_camel_case_types)] struct SetRowDataSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetRowDataSvc { + impl tonic::server::UnaryService + for SetRowDataSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5262,15 +4914,9 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/DragRow" => { #[allow(non_camel_case_types)] struct DragRowSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for DragRowSvc { + impl tonic::server::UnaryService for DragRowSvc { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5308,15 +4954,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerSlot" => { #[allow(non_camel_case_types)] struct TriggerSlotSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerSlotSvc { + impl tonic::server::UnaryService + for TriggerSlotSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5354,15 +4996,9 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/DragSlot" => { #[allow(non_camel_case_types)] struct DragSlotSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for DragSlotSvc { + impl tonic::server::UnaryService for DragSlotSvc { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5400,15 +5036,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/ImportFiles" => { #[allow(non_camel_case_types)] struct ImportFilesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for ImportFilesSvc { + impl tonic::server::UnaryService + for ImportFilesSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5446,15 +5078,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerClip" => { #[allow(non_camel_case_types)] struct TriggerClipSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerClipSvc { + impl tonic::server::UnaryService + for TriggerClipSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5492,15 +5120,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetClipName" => { #[allow(non_camel_case_types)] struct SetClipNameSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetClipNameSvc { + impl tonic::server::UnaryService + for SetClipNameSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5538,15 +5162,11 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetClipData" => { #[allow(non_camel_case_types)] struct SetClipDataSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetClipDataSvc { + impl tonic::server::UnaryService + for SetClipDataSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5584,15 +5204,9 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/DragClip" => { #[allow(non_camel_case_types)] struct DragClipSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for DragClipSvc { + impl tonic::server::UnaryService for DragClipSvc { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, @@ -5630,23 +5244,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/TriggerSequence" => { #[allow(non_camel_case_types)] struct TriggerSequenceSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for TriggerSequenceSvc { + impl + tonic::server::UnaryService + for TriggerSequenceSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::trigger_sequence(&inner, request) - .await + ::trigger_sequence(&inner, request).await }; Box::pin(fut) } @@ -5677,23 +5287,19 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SetSequenceInfo" => { #[allow(non_camel_case_types)] struct SetSequenceInfoSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService - for SetSequenceInfoSvc { + impl + tonic::server::UnaryService + for SetSequenceInfoSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::set_sequence_info(&inner, request) - .await + ::set_sequence_info(&inner, request).await }; Box::pin(fut) } @@ -5724,29 +5330,22 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/SaveCustomCompartmentData" => { #[allow(non_camel_case_types)] struct SaveCustomCompartmentDataSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::UnaryService< - super::SaveCustomCompartmentDataRequest, - > for SaveCustomCompartmentDataSvc { + impl + tonic::server::UnaryService + for SaveCustomCompartmentDataSvc + { type Response = super::Empty; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::SaveCustomCompartmentDataRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::save_custom_compartment_data( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -5777,30 +5376,25 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalGlobalUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalGlobalUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalGlobalUpdatesRequest, - > for GetOccasionalGlobalUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetOccasionalGlobalUpdatesRequest, + > for GetOccasionalGlobalUpdatesSvc + { type Response = super::GetOccasionalGlobalUpdatesReply; type ResponseStream = T::GetOccasionalGlobalUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalGlobalUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::get_occasional_global_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -5830,20 +5424,16 @@ pub mod helgobox_service_server { } "/generated.HelgoboxService/GetOccasionalPlaytimeEngineUpdates" => { #[allow(non_camel_case_types)] - struct GetOccasionalPlaytimeEngineUpdatesSvc( - pub Arc, - ); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalPlaytimeEngineUpdatesRequest, - > for GetOccasionalPlaytimeEngineUpdatesSvc { + struct GetOccasionalPlaytimeEngineUpdatesSvc(pub Arc); + impl + tonic::server::ServerStreamingService< + super::GetOccasionalPlaytimeEngineUpdatesRequest, + > for GetOccasionalPlaytimeEngineUpdatesSvc + { type Response = super::GetOccasionalPlaytimeEngineUpdatesReply; type ResponseStream = T::GetOccasionalPlaytimeEngineUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, request: tonic::Request< @@ -5853,10 +5443,9 @@ pub mod helgobox_service_server { let inner = Arc::clone(&self.0); let fut = async move { ::get_occasional_playtime_engine_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -5886,33 +5475,26 @@ pub mod helgobox_service_server { } "/generated.HelgoboxService/GetOccasionalInstanceUpdates" => { #[allow(non_camel_case_types)] - struct GetOccasionalInstanceUpdatesSvc( - pub Arc, - ); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalInstanceUpdatesRequest, - > for GetOccasionalInstanceUpdatesSvc { + struct GetOccasionalInstanceUpdatesSvc(pub Arc); + impl + tonic::server::ServerStreamingService< + super::GetOccasionalInstanceUpdatesRequest, + > for GetOccasionalInstanceUpdatesSvc + { type Response = super::GetOccasionalInstanceUpdatesReply; type ResponseStream = T::GetOccasionalInstanceUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalInstanceUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::get_occasional_instance_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -5943,29 +5525,22 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalUnitUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalUnitUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalUnitUpdatesRequest, - > for GetOccasionalUnitUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetOccasionalUnitUpdatesRequest, + > for GetOccasionalUnitUpdatesSvc + { type Response = super::GetOccasionalUnitUpdatesReply; type ResponseStream = T::GetOccasionalUnitUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalUnitUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_occasional_unit_updates( - &inner, - request, - ) + ::get_occasional_unit_updates(&inner, request) .await }; Box::pin(fut) @@ -5997,30 +5572,25 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalMatrixUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalMatrixUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalMatrixUpdatesRequest, - > for GetOccasionalMatrixUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetOccasionalMatrixUpdatesRequest, + > for GetOccasionalMatrixUpdatesSvc + { type Response = super::GetOccasionalMatrixUpdatesReply; type ResponseStream = T::GetOccasionalMatrixUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalMatrixUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::get_occasional_matrix_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -6051,30 +5621,25 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetContinuousMatrixUpdates" => { #[allow(non_camel_case_types)] struct GetContinuousMatrixUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetContinuousMatrixUpdatesRequest, - > for GetContinuousMatrixUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetContinuousMatrixUpdatesRequest, + > for GetContinuousMatrixUpdatesSvc + { type Response = super::GetContinuousMatrixUpdatesReply; type ResponseStream = T::GetContinuousMatrixUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetContinuousMatrixUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::get_continuous_matrix_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -6105,30 +5670,25 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalColumnUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalColumnUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalColumnUpdatesRequest, - > for GetOccasionalColumnUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetOccasionalColumnUpdatesRequest, + > for GetOccasionalColumnUpdatesSvc + { type Response = super::GetOccasionalColumnUpdatesReply; type ResponseStream = T::GetOccasionalColumnUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalColumnUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::get_occasional_column_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -6159,30 +5719,25 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetContinuousColumnUpdates" => { #[allow(non_camel_case_types)] struct GetContinuousColumnUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetContinuousColumnUpdatesRequest, - > for GetContinuousColumnUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetContinuousColumnUpdatesRequest, + > for GetContinuousColumnUpdatesSvc + { type Response = super::GetContinuousColumnUpdatesReply; type ResponseStream = T::GetContinuousColumnUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetContinuousColumnUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::get_continuous_column_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -6213,30 +5768,25 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalTrackUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalTrackUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalTrackUpdatesRequest, - > for GetOccasionalTrackUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetOccasionalTrackUpdatesRequest, + > for GetOccasionalTrackUpdatesSvc + { type Response = super::GetOccasionalTrackUpdatesReply; type ResponseStream = T::GetOccasionalTrackUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalTrackUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { ::get_occasional_track_updates( - &inner, - request, - ) - .await + &inner, request, + ) + .await }; Box::pin(fut) } @@ -6267,29 +5817,21 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalRowUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalRowUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalRowUpdatesRequest, - > for GetOccasionalRowUpdatesSvc { + impl + tonic::server::ServerStreamingService + for GetOccasionalRowUpdatesSvc + { type Response = super::GetOccasionalRowUpdatesReply; type ResponseStream = T::GetOccasionalRowUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalRowUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_occasional_row_updates( - &inner, - request, - ) + ::get_occasional_row_updates(&inner, request) .await }; Box::pin(fut) @@ -6321,29 +5863,22 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalSlotUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalSlotUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalSlotUpdatesRequest, - > for GetOccasionalSlotUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetOccasionalSlotUpdatesRequest, + > for GetOccasionalSlotUpdatesSvc + { type Response = super::GetOccasionalSlotUpdatesReply; type ResponseStream = T::GetOccasionalSlotUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalSlotUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_occasional_slot_updates( - &inner, - request, - ) + ::get_occasional_slot_updates(&inner, request) .await }; Box::pin(fut) @@ -6375,29 +5910,22 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetContinuousSlotUpdates" => { #[allow(non_camel_case_types)] struct GetContinuousSlotUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetContinuousSlotUpdatesRequest, - > for GetContinuousSlotUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetContinuousSlotUpdatesRequest, + > for GetContinuousSlotUpdatesSvc + { type Response = super::GetContinuousSlotUpdatesReply; type ResponseStream = T::GetContinuousSlotUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetContinuousSlotUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_continuous_slot_updates( - &inner, - request, - ) + ::get_continuous_slot_updates(&inner, request) .await }; Box::pin(fut) @@ -6429,29 +5957,22 @@ pub mod helgobox_service_server { "/generated.HelgoboxService/GetOccasionalClipUpdates" => { #[allow(non_camel_case_types)] struct GetOccasionalClipUpdatesSvc(pub Arc); - impl< - T: HelgoboxService, - > tonic::server::ServerStreamingService< - super::GetOccasionalClipUpdatesRequest, - > for GetOccasionalClipUpdatesSvc { + impl + tonic::server::ServerStreamingService< + super::GetOccasionalClipUpdatesRequest, + > for GetOccasionalClipUpdatesSvc + { type Response = super::GetOccasionalClipUpdatesReply; type ResponseStream = T::GetOccasionalClipUpdatesStream; - type Future = BoxFuture< - tonic::Response, - tonic::Status, - >; + type Future = + BoxFuture, tonic::Status>; fn call( &mut self, - request: tonic::Request< - super::GetOccasionalClipUpdatesRequest, - >, + request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - ::get_occasional_clip_updates( - &inner, - request, - ) + ::get_occasional_clip_updates(&inner, request) .await }; Box::pin(fut) @@ -6480,18 +6001,14 @@ pub mod helgobox_service_server { }; Box::pin(fut) } - _ => { - Box::pin(async move { - Ok( - http::Response::builder() - .status(200) - .header("grpc-status", "12") - .header("content-type", "application/grpc") - .body(empty_body()) - .unwrap(), - ) - }) - } + _ => Box::pin(async move { + Ok(http::Response::builder() + .status(200) + .header("grpc-status", "12") + .header("content-type", "application/grpc") + .body(empty_body()) + .unwrap()) + }), } } } diff --git a/main/src/infrastructure/ui/app/app_library.rs b/main/src/infrastructure/ui/app/app_library.rs index b54c916a5..e4b99a16c 100644 --- a/main/src/infrastructure/ui/app/app_library.rs +++ b/main/src/infrastructure/ui/app/app_library.rs @@ -16,13 +16,13 @@ use playtime_clip_engine::base::Matrix; use prost::Message; use reaper_high::Reaper; use reaper_low::raw::HWND; +use reaper_medium::Hwnd; use semver::Version; use std::env; use std::ffi::{c_char, c_uint, c_void, CStr, CString}; use std::future::Future; use std::path::{Path, PathBuf}; use std::ptr::{null_mut, NonNull}; -use reaper_medium::Hwnd; use swell_ui::Window; use tonic::Status; @@ -50,7 +50,7 @@ impl AppLibrary { "window_manager_plugin.dll", "pointer_lock_plugin.dll", ] - .as_slice(), + .as_slice(), ) } else if cfg!(target_os = "macos") { ( @@ -504,7 +504,7 @@ fn process_command( .unwrap(); create_initial_instance_updates(&instance_shell) }) - .map_err(to_status)?; + .map_err(to_status)?; } GetOccasionalUnitUpdates(req) => { send_initial_events_to_app(instance_id, || { @@ -513,7 +513,7 @@ fn process_command( .unwrap(); create_initial_unit_updates(&instance_shell) }) - .map_err(to_status)?; + .map_err(to_status)?; } GetOccasionalPlaytimeEngineUpdates(_) => { #[cfg(not(feature = "playtime"))] @@ -526,7 +526,7 @@ fn process_command( instance_id, crate::infrastructure::proto::create_initial_engine_updates, ) - .map_err(to_status)?; + .map_err(to_status)?; } } GetOccasionalMatrixUpdates(req) => { @@ -542,7 +542,7 @@ fn process_command( req.matrix_id.into(), proto::create_initial_matrix_updates, ) - .map_err(to_status)?; + .map_err(to_status)?; } } GetOccasionalTrackUpdates(req) => { @@ -558,7 +558,7 @@ fn process_command( req.matrix_id.into(), proto::create_initial_track_updates, ) - .map_err(to_status)?; + .map_err(to_status)?; } } GetOccasionalSlotUpdates(req) => { @@ -574,7 +574,7 @@ fn process_command( req.matrix_id.into(), proto::create_initial_slot_updates, ) - .map_err(to_status)?; + .map_err(to_status)?; } } GetOccasionalClipUpdates(req) => { @@ -590,7 +590,7 @@ fn process_command( req.matrix_id.into(), proto::create_initial_clip_updates, ) - .map_err(to_status)?; + .map_err(to_status)?; } } // Normal commands @@ -761,7 +761,7 @@ fn send_event_reply_to_app(instance_id: InstanceId, value: event_reply::Value) - fn send_query_reply_to_app( instance_id: InstanceId, req_id: u32, - future: impl Future> + Send + 'static, + future: impl Future> + Send + 'static, ) { Global::future_support().spawn_in_main_thread(async move { let query_result_value = match future.await { diff --git a/swell-ui/src/window.rs b/swell-ui/src/window.rs index ff1edd879..126f4130e 100644 --- a/swell-ui/src/window.rs +++ b/swell-ui/src/window.rs @@ -350,7 +350,7 @@ impl Window { // difference because moving is not a problem in all known cases. pub fn fill_combo_box_with_data( self, - items: impl ExactSizeIterator, + items: impl ExactSizeIterator, ) { self.clear_combo_box(); self.maybe_init_combo_box_storage(items.len()); @@ -362,13 +362,13 @@ impl Window { /// Okay to use if approximately less than 100 items, otherwise might become slow. pub fn fill_combo_box_with_data_small( self, - items: impl Iterator, + items: impl Iterator, ) { self.clear_combo_box(); self.fill_combo_box_with_data_internal(items); } - pub fn fill_combo_box_indexed(self, items: impl ExactSizeIterator) { + pub fn fill_combo_box_indexed(self, items: impl ExactSizeIterator) { self.clear_combo_box(); self.maybe_init_combo_box_storage(items.len()); for item in items { @@ -380,7 +380,7 @@ impl Window { self.fill_combo_box_indexed(items.into_iter()); } - pub fn fill_combo_box_small(self, items: impl Iterator) { + pub fn fill_combo_box_small(self, items: impl Iterator) { self.clear_combo_box(); for item in items { self.add_combo_box_item(item.to_string()); @@ -399,7 +399,7 @@ impl Window { fn fill_combo_box_with_data_internal( self, - items: impl Iterator, + items: impl Iterator, ) { for (i, (data, item)) in items.enumerate() { self.insert_combo_box_item_with_data(i, data, item.to_string()); @@ -865,7 +865,7 @@ impl Window { x: Pixels(rect.right as u32), y: Pixels(rect.bottom as u32), } - .into() + .into() } #[cfg(target_family = "unix")] point.in_pixels().into() @@ -884,7 +884,7 @@ impl Window { DialogUnits((point.x.get() as f64 / x_factor).round() as u32), DialogUnits((point.y.get() as f64 / y_factor).round() as u32), ) - .into() + .into() } /// Calculates the dialog-unit to pixel scaling factors for each axis.