rx_bevy_observable_keyboard 0.3.2

use bevy_input::keyboard::KeyCode;
use rx_bevy_common::RxBevyScheduler;
use rx_core_common::{Never, Observable, SchedulerHandle, Subscriber, UpgradeableObserver};
use rx_core_macro_observable_derive::RxObservable;

use crate::{KeyboardObservableOptions, KeyboardSubscription};

/// # [KeyboardObservable]
///
/// The `KeyboardObservable` turns Bevy keyboard input events into signals. The
/// events are sourced from the `ButtonInput<KeyCode>` resource.
///
/// ## Options
///
/// `KeyCode` signals can be observed in multiple modes:
///
/// - `KeyboardObservableEmit::JustPressed` - emits once when the key is pressed down.
/// - `KeyboardObservableEmit::JustReleased` - emits once when the key is released.
/// - `KeyboardObservableEmit::WhilePressed` - emits continuously while the key is held down.
#[derive(RxObservable)]
#[rx_out(KeyCode)]
#[rx_out_error(Never)]
pub struct KeyboardObservable {
	options: KeyboardObservableOptions,
	scheduler: SchedulerHandle<RxBevyScheduler>,
}

impl KeyboardObservable {
	pub fn new(
		options: KeyboardObservableOptions,
		scheduler: SchedulerHandle<RxBevyScheduler>,
	) -> Self {
		Self { options, scheduler }
	}
}

impl Observable for KeyboardObservable {
	type Subscription<Destination>
		= KeyboardSubscription<Destination>
	where
		Destination: 'static + Subscriber<In = Self::Out, InError = Self::OutError>;

	fn subscribe<Destination>(
		&mut self,
		destination: Destination,
	) -> Self::Subscription<Destination::Upgraded>
	where
		Destination:
			'static + UpgradeableObserver<In = Self::Out, InError = Self::OutError> + Send + Sync,
	{
		KeyboardSubscription::new(
			destination.upgrade(),
			self.options.clone(),
			self.scheduler.clone(),
		)
	}
}