static class EncryptionExtensions { static IObservable<byte…

Twetch · October 18, 2019

static class EncryptionExtensions { static IObservable<byte[]> Encrypt<T>(this IObservable<T> source, byte[] key, byte[] IV) where T:LambdaExpression { return Observable.Create<byte[]>(o => source.Subscribe(t => {

Replies

Twetch · October 18, 2019

using(var aes = Aes.Create()) {
var encryptor = aes.CreateEncryptor(key, IV);
using (var ms = new MemoryStream()) {
using (var cs = new CryptoStream(ms, encryptor, CryptoStreamMode.Write)) {

Twetch · October 18, 2019

var formatter = new BinaryFormatter();
formatter.Serialize(cs, t);
}
var encrypted = ms.ToArray();
o.OnNext(encrypted);
o.OnCompleted(); }}));
}