rust/azure_iot_operations_mqtt/src/session/session.rs (8 lines):
	- line 57: // TODO: get client id out of here
	- line 58: // TODO: can we eliminate need for box on input?
	- line 135: // TODO: This should happen in the auth module, it should be fixed in the future.
	- line 216: // TODO: This is a bit of a hack, but it works for now. Ideally, the reauth
	- line 291: // TODO: However, this has the side-effect of falsely reporting disconnects that are the
	- line 509: // TODO: There might be a way to optimize this a bit better if we know we're disconnected,
	- line 532: // TODO: This doesn't actually end the MQTT session because rumqttc doesn't allow
	- line 541: // TODO: This doesn't actually end the MQTT session because rumqttc doesn't allow


rust/azure_iot_operations_protocol/src/rpc_command/invoker.rs (7 lines):
	- line 243: // TODO: We may want to narrow this logic a bit to cover only valid cases.
	- line 1287: // TODO: This dependency on MqttConnectionSettingsBuilder should be removed in lieu of using a true mock
	- line 1298: // TODO: This should return a mock ManagedClient instead.
	- line 1575: // TODO: Check for
	- line 1645: // TODO: Check for
	- line 1704: // TODO: Check for
	- line 1765: // TODO: Check for


rust/azure_iot_operations_services/src/schema_registry/client.rs (6 lines):
	- line 31: client_id: String, // TODO: Temporary until the schema registry service updates their executor
	- line 60: client_id: client.client_id().to_string(), // TODO: Temporary until the schema registry service updates their executor
	- line 101: .custom_user_data(vec![("__invId".to_string(), self.client_id.clone())]) // TODO: Temporary until the schema registry service updates their executor
	- line 163: .custom_user_data(vec![("__invId".to_string(), self.client_id.clone())]) // TODO: Temporary until the schema registry service updates their executor
	- line 218: // TODO: This should return a mock ManagedClient instead.
	- line 222: // TODO: Make a real mock that implements MqttProvider


rust/azure_iot_operations_mqtt/src/rumqttc_adapter.rs (3 lines):
	- line 301: // TODO: This error story needs improvement once we find out how much of this
	- line 312: // TODO: As above, this will potentially be updated once final TLS implementation takes shape
	- line 505: // CA Revocation Check TODO: add this back in


rust/azure_iot_operations_mqtt/src/interface.rs (3 lines):
	- line 16: pub use crate::session::receiver::AckToken; // TODO: remove this pub re-export after concretized receivers / managed clients
	- line 50: // TODO: Re-implement these instead of just aliasing / add to rumqttc adapter
	- line 138: // TODO: consider scoping this to also include a `connect`. Not currently needed, but would be more flexible,


rust/azure_iot_operations_services/src/state_store/client.rs (3 lines):
	- line 665: // TODO: This dependency on MqttConnectionSettingsBuilder should be removed in lieu of using a true mock
	- line 672: // TODO: This should return a mock ManagedClient instead.
	- line 676: // TODO: Make a real mock that implements MqttProvider


rust/azure_iot_operations_mqtt/src/interface_mocks.rs (3 lines):
	- line 155: // TODO: set return value(s) for calls, or perhaps full implementations of the call
	- line 158: // TODO: Will need to add a way to choose when acks return, and what rc they provide
	- line 188: // TODO: Need to flesh out the mock more


rust/azure_iot_operations_mqtt/src/connection_settings.rs (3 lines):
	- line 10: // TODO: Split up this struct to avoid weird combinations and separate concern.
	- line 29: //TODO: This is probably better represented as an option. Do this when refactoring.
	- line 37: // TODO: Would this would be better represented as an integer (probably, due to max value having distinct meaning in MQTT)


rust/azure_iot_operations_protocol/src/telemetry/receiver.rs (3 lines):
	- line 585: // TODO: change API around this receive to simplify
	- line 702: // TODO: This should return a mock Session instead
	- line 704: // TODO: Make a real mock that implements Session


rust/azure_iot_operations_protocol/src/telemetry/sender.rs (2 lines):
	- line 532: // TODO: This should return a mock MqttProvider instead
	- line 534: // TODO: Make a real mock that implements MqttProvider


dotnet/src/Azure.Iot.Operations.Mqtt/Session/MqttSessionClient.cs (2 lines):
	- line 94: //TODO once the session client is fully integrated into RPC/Telemetry tests, the default session expiry interval should be 0
	- line 830: //TODO there is room for a lot more nuance here. Some socket exceptions are more retryable than others so it may


dotnet/src/Azure.Iot.Operations.Services/StateStore/StateStoreObject.cs (2 lines):
	- line 28: //TODO try deferring the reading of the stream for later
	- line 47: //TODO try deferring the reading of the stream for later


rust/azure_iot_operations_mqtt/src/session.rs (2 lines):
	- line 45: pub mod managed_client; // TODO: This really ought be private, but we need it public for testing
	- line 51: pub mod session; // TODO: Make this private and accessible via compile flags


dotnet/src/Azure.Iot.Operations.Protocol/RPC/CommandInvoker.cs (2 lines):
	- line 560: // TODO remove this once akri service is code gen'd to expect srcId instead of invId
	- line 679: // TODO #208


rust/azure_iot_operations_protocol/src/rpc_command/executor.rs (2 lines):
	- line 1400: // TODO: This dependency on MqttConnectionSettingsBuilder should be removed in lieu of using a true mock
	- line 1407: // TODO: This should return a mock ManagedClient instead.


go/services/leasedlock/lock.go (2 lines):
	- line 51: //nolint:errcheck // TODO: Is there anything useful to do if this fails?
	- line 134: //nolint:errcheck // TODO: Is there anything useful to do if this fails?


dotnet/src/Azure.Iot.Operations.Services/Assets/FilesMonitor/FilesMonitor.cs (1 line):
	- line 87: //TODO need testing on file create/delete cases


go/protocol/telemetry_receiver.go (1 line):
	- line 211: // TODO: This goroutine will leak if the handler blocks without respecting


rust/azure_iot_operations_mqtt/src/lib.rs (1 line):
	- line 23: // TODO: put behind `use-rumqttc` feature flag


rust/azure_iot_operations_mqtt/src/control_packet.rs (1 line):
	- line 6: // TODO: Re-implement these instead of just aliasing / add to rumqttc adapter


rust/azure_iot_operations_mqtt/Cargo.toml (1 line):
	- line 15: anyhow = "1.0.86"                                                                   # TODO: reconsider inclusion once TLS library is finalized


go/mqtt/publish.go (1 line):
	- line 88: // TODO: Add real PUBACK information once Paho exposes it.


dotnet/src/Azure.Iot.Operations.Protocol/AkriSystemProperties.cs (1 line):
	- line 76: // TODO remove this once akri service is code gen'd to expect srcId instead of invId


rust/azure_iot_operations_mqtt/src/topic.rs (1 line):
	- line 14: // TODO: $ rules are not supported yet


go/services/statestore/notify.go (1 line):
	- line 108: // TODO: Lock less globally if possible, but keep it simple for now.


rust/azure_iot_operations_protocol/src/common/payload_serialize.rs (1 line):
	- line 192: // TODO: Remove this mutex. Find a better way to control test ordering


go/services/statestore/reconnect.go (1 line):
	- line 24: //nolint:errcheck // TODO: Is there anything useful to do if this fails?


go/services/schemaregistry/client.go (1 line):
	- line 21: // TODO: Remove when no longer necessary for compat.


rust/azure_iot_operations_mqtt/src/session/wrapper.rs (1 line):
	- line 76: // TODO: consider user properties from being supported on SessionOptions or ConnectionSettings


go/protocol/command_executor.go (1 line):
	- line 289: // TODO: This goroutine will leak if the handler blocks without respecting