Based on my analysis, here's my approach to convert the Progress<> callbacks to use Rx.NET with throttling:
Analysis and Approach
Current State
| sudo su | |
| unset HISTFILE | |
| cat /etc/os-release | |
| exit | |
| history | |
| # Check History: | |
| unset HISTFILE | |
| sudo su | |
| unset HISTFILE |
| echo "test worked" |
kubectl set env deployment nginx-admin DEPLOY_DATE="$(date)"
kubectl logs rs-oidc-d58f7dccf-wfzl7 --follow | tee >(grep -v "^{") | grep "^{" | jq .
kubectl logs $(k8p rs-oidc) --follow | tee >(grep -v "^{") | grep "^{" | jq .
Reference
export MYZK=z-2.kafka-cluster-dev.wi53u7.c7.kafka.us-east-1.amazonaws.com:2181 kafka-topics --list --zookeeper ${MYZK} | xargs
| # Example command for running within osx: | |
| curl -s -L https://bit.ly/rs-rsi-osx | bash |
| { | |
| "section-launches": { | |
| "aliases": {}, | |
| "mappings": { | |
| "properties": { | |
| "processKey": { | |
| "type": "text", | |
| "fields": { | |
| "keyword": { | |
| "type": "keyword", |
| #!/usr/bin/python3 | |
| import os, sys, getopt | |
| import syslog | |
| def log(s): | |
| print(s) | |
| syslog.syslog(s) | |
| def main(argv): | |
| directory = os.popen('pwd').read().split("\n")[0] |
| #!/bin/bash | |
| set -e | |
| set -u | |
| set -o pipefail | |
| debug=0 | |
| purge=0 | |
| follow=0 | |
| while getopts 'c:fpn:v' OPTION; do |
| #!/bin/bash | |
| SRC_DIR=$1 | |
| DST_DIR=$2 | |
| if ! [ -d "$SRC_DIR" ]; then | |
| echo "Directory specified to watch does not exist." | |
| fi | |
| if ! [ -d "$DST_DIR" ]; then |
| public static class MessageConverter | |
| { | |
| private static InheritedTypeConverter<IMessage> _default = null; | |
| public static InheritedTypeConverter<IMessage> Default | |
| { | |
| get | |
| { | |
| // TODO would be nice to have an attribute I could plug onto classes and have it "auto" find the classes through an assembly | |
| if (_default == null) |