static IObservable<T> Decrypt<T>(this IObservable<byte[]> source, byte[] key, byte[] IV)…

1AKHViYgBGbmxi8qiJkNvoHNeDu9m3MfPE (2159) · October 18, 2019

static IObservable<T> Decrypt<T>(this IObservable<byte[]> source, byte[] key, byte[] IV) {
return Observable.Create<T>(o =>
source.Subscribe(t => {

Replies

1AKHViYgBGbmxi8qiJkNvoHNeDu9m3MfPE (2159) · October 18, 2019

using(var aes = Aes.Create()) {
var decryptor = aes.CreateDecryptor(key, IV);
using (var ms = new MemoryStream(t)) {
using (var cs = new CryptoStream(ms, decryptor, CryptoStreamMode.Read)) {

1AKHViYgBGbmxi8qiJkNvoHNeDu9m3MfPE (2159) · October 18, 2019

var formatter = new BinaryFormatter();
T decrypted = (T)formatter.Deserialize(cs);
try {
o.OnNext(decrypted);
o.OnCompleted();
} catch(CryptographicException cex) {
o.OnError(cex);
}
}

1AKHViYgBGbmxi8qiJkNvoHNeDu9m3MfPE (2159) · October 18, 2019

var formatter = new BinaryFormatter();
T decrypted = (T)formatter.Deserialize(cs);
try {
o.OnNext(decrypted);
o.OnCompleted();
} catch(CryptographicException cex) {
o.OnError(cex);}}}}}));}}